百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT知识 > 正文

从STL到THRUST,CUDA代码封装诀窍,让CUDA代码像C++一样优美

liuian 2024-12-23 12:11 30 浏览

cuda代码虽然可以使用计算设备达到超高并行化,超高吞吐的效果,但是写起来大部分面向过程,优美性和灵活性都有所欠缺,这就促使我们思考,能不能像C封装成C++一样,做一些简单封装,让二者的融合度更高,让CUDA的编程更友好?

thrust应运而生。它支持host和device两种vector,同时提供了类似STL的五大功能:

  • 变换 (transformation)
  • 规约 (reduction)
  • 前缀和 (prefix sum)
  • 排序 (sorting), 搜索(searching)
  • 选择性复制、替换、移除、分区等重排(reordering) 操作

在这里,我们将分析几种关键功能实现和设计思路,方便理解和拓展thrust相关的开发。

使用中间层将C++类, CUDA代码分离

cuda中kernel的使用大致如下:

// 定义

__global__ void functionA_kernel_step(args) {}

__global__ void functionA_kernel_step2(args) {}

//调用:

functionA_kernel_step<<<1, 5>>>(args);

functionA_kernel_step2<<<1, 5>>>(args);


这样不仅繁琐,而且不易理解。C++中广泛采用的面向对象,一般会将函数描述成某个class的成员,类似:

class Master {

public:

Master();

~Master();

void CallMonster();

void DismissMonsters();

};

class Monster {

public:

Monster();

~Monster();

void Attack(Other something);

};

假设attack这里是核函数的形式调用,我们希望C++代码尽量整洁。

这点倒是易于攻破,只需要将kernel的调用封装到另一个文件里,C++中调用对应的功能即可。

// file: action.cu

__global__ void monster_attack() {

}

void CallAttack() {

kernel<<<3, 3>>>monster_attack();

}

// file: action.h

void CallAttack();

// file: monster.cpp

#include "action.h"

void Monster::Attack(Other something) {

CallAttack();

}

容器内存复制功能封装

这样组织文件可以让Cpp部分的代码独立一些,便于设计。kernel的实现并没有多少优化。我们还需要进一步实现一些必须的“轮子”。

C++中最广泛使用的数据结构是vector和map(unordered_map), map的设计过于复杂,这里不多加描述。如果是vector,排除realloc的部分,其实都是访问一块连续内存。

暂时不考虑iterator的封装的话,我们也可以设计一个简洁的,能直接从C++的vector中复制对应Vector的类。

class MasterIntVector {

public:

MasterIntVector(const std::vector<int> &array) {

n = array.size();

cudaMalloc((void**)(a), n * sizeof(int));

cudaMemcpy((void**)(a), array.data(), n * sizeof(int), cudaHostToDevice, 0);

}

MasterIntVector(int len) {

n = len;

cudaMalloc((void**)(a), n * sizeof(int));

cudaMemcpy((void**)(a), array.data(), n * sizeof(int), cudaHostToDevice, 0);

}

~MasterIntVector() {cudaFree(a);}

const int* begin() {

return a;

}

const int* end() {

return a + n;

}

private:

int *a;

}

自定义函数类型的封装和传递

有了这个简陋的封装类,我们就可以使用类似STL里的for_each功能,例如,对每个元素增加42。

// for_each.cu

__global__ void for_each_kernel(int *data, int n, func_type func) {

for (int i = 0; i < n; i++) func(data[i]);

}

void for_each(int *begin, int *end, func_type func) {

int n = end - begin;

for_each_kernel<<<1, end - begin>>>(begin, n, func);

}

// for_each.c++

typedef int(*func_type)(int);

__device__ __host__ int Add42(int x) {

return x+42;

}

for (int i=0; i<n; i++) {

cpu_monster.push_back(i); //创建一个顺序的vector

}

MasterIntVector a {cpu_monster};

for_each(a.begin(), a.end(), Add42); // WRONG!!! HOW????

这里就引入第三个需要处理的封装问题:如何在C++代码中向核函数传入对应的自定义函数;

一般在host端,能获得的函数地址都是host端的。直接将Add42这个地址传入,在device中并不能执行。__device__和__host__宏定义的意义在于,在kernel函数和host端,都能找到这个符号对应的地址,无法负责两个地址间的访问转换。

不过,有另一个使得函数内容能够拷贝到device的方式:使用struct定义functor。

struct Add42 {

__device__ __host__ int operator()(int x) {

return x + 42;

}

}

调用的时候,需要创建一个Add42类型的实例,同时把func_type的定义修改下;

using func_type = Add42;

for_each(a.begin(), a.end(), Add42{});

这样,我们就实现了可拓展的for_each操作。

相关推荐

Springboot 整合 Websocket 轻松实现IM及时通讯

一、方案实践集成分为三步:添加依赖、增加配置类和消息核心类、前端集成。1.1、添加依赖<dependency><groupId>org.springframework...

SpringBoot扩展——应用Web Socket!

应用WebSocket目前,网络上的即时通信App有很多,如QQ、微信和飞书等,按照以往的技术来说,即时功能通常会采用服务器轮询和Comet技术来解决。HTTP是非持久化、单向的网络协议,在建立连接...

【Spring Boot】WebSocket 的 6 种集成方式

介绍由于前段时间我实现了一个库【SpringCloud】一个配置注解实现WebSocket集群方案以至于我对WebSocket的各种集成方式做了一些研究目前我所了解到的就是下面这些了(就一个破w...

SpringBoot生产级WebSocket集群实践,支持10万连接!

1、问题背景智慧门诊系统旨在从一定程度上解决患者面临的三长一短(挂号、看病、取药时间长,医生问诊时间短)的问题。实现“诊前、诊中、诊后”实时智能一体化,整合完善医院工作流程。围绕门诊看病的各个环节,让...

Spring Boot3 中 WebSocket 实现数据实时通信全解析

各位互联网大厂的开发同仁们,在如今的互联网应用开发中,实时通信功能越来越重要。比如在线聊天、数据推送、实时通知等场景,都离不开高效的实时通信技术。而WebSocket作为一种高效的双向通信协议,在...

Java WebSocket 示例(java nio websocket)

一、环境准备1.依赖配置(Maven)在pom.xml中添加WebSocket依赖:xml<!--SpringBootWebSocket--><dependen...

Spring Boot整合WebSocket:开启实时通信之旅

SpringBoot整合WebSocket:开启实时通信之旅今天咱们来聊聊SpringBoot整合WebSocket这件大事儿。说到实时通信,你是不是第一时间想到QQ、微信这些聊天工具?没错,We...

Spring Boot3 竟能如此轻松整合 WebSocket 技术,你还不知道?

在当今互联网大厂的软件开发领域,实时通信的需求愈发迫切。无论是在线聊天应用、实时数据更新,还是协同办公系统,都离不开高效的实时通信技术支持。而WebSocket作为一种能够实现浏览器与服务器之间持...

Spring Boot集成WebSocket(springboot集成websocket)

一、基础配置依赖引入<dependency><groupId>org.springframework.boot</groupId><artifactId>...

Springboot下的WebSocket开发(springboot websocket server)

今天遇到一个需求,需要对接第三方扫码跳转。一种方案是前端页面轮询后端服务,但是这种空轮询会虚耗资源,实时性比较差而且也不优雅。所以决定使用另一种方案,websocket。以前就知道websocket,...

springboot websocket开发(java spring boot websocket)

maven依赖SpringBoot2.0对WebSocket的支持简直太棒了,直接就有包可以引入<dependency><groupId>org....

Python界面(GUI)编程PyQt5窗体小部件

一、简介在Qt(和大多数用户界面)中,“小部件”是用户可以与之交互的UI组件的名称。用户界面由布置在窗口内的多个小部件组成。Qt带有大量可用的小部件,也允许您创建自己的自定义和自定义小部件。二、小部件...

实战PyQt5: 014-下拉列表框控件QComboBox

QComboBox简介QComboBox下拉列表框,是一个集按钮和下拉列表选项于一体的部件。QComboBox提供了一种向用户呈现选项列表的方式,其占用最小量的屏幕空间。QComboBox中的常用方法...

Python小白逆袭!7天吃透PyQt6,独立开发超酷桌面应用

PythonGUI编程:PyQt6从入门到实战的全面指南在Python的庞大生态系统中,PyQt6作为一款强大的GUI(GraphicalUserInterface,图形用户界面)编程框架,为开...

如何用 PyQt6 打造一个功能完善的 SQLite 数据库管理工具

如何使用PyQt6和qt_material库,打造一个功能完善的SQLite数据库管理工具,轻松管理和查询SQLite数据库。一、目标数据库连接与表管理:支持连接SQLite数据库...