1:场景是有一个线程池,我需要将任务队列中发生读写事件的fd拿出来传递到线程池中正常情况下创建线程时可以指定参数,比如这样
线程池
任务队列
fd
std::thread t(func,arg1,arg2,...)
但是我的fd是在线程已经创建好之后传入,那该怎么办?
业精于勤,荒于嬉;行成于思,毁于随。
线程之间传递数据并不需要什么特殊的手段,因为线程的大部分数据都是共享的,全局变量、静态全局变量和通过指针传递的数据都是可以直接在线程之间共享的。所以最简单的方法就是定义一个全局的队列,这样每个线程都可以访问到这个队列,主线程把fd写入队列,线程池中的线程都从这个队列中取数据就可以了。当然你也可以把队列的引用通过参数传给每一个线程。考虑到这个C++标准库的queue不是线程安全的,你可能需要用锁来保证队列的线程安全.
随便传啊,比如全局变量,堆上的内存块,只要不是tls线程局部存储的都可以用来传输,但前提是必须用锁控制。你可以选择互斥量等来做读写控制。
tls
线程池接收的是一个操作,不是一个值…线程池里的线程就算已经创建了也是阻塞在队列里…只需要往线程池里投递一个带有fd的操作就可以了…如果线程池里已经有一个操作在阻塞等待fd进来,那也会存在一个条件变量去阻塞线程运行…fd准备好了通知条件变量就可以…
Windows下可以考虑PostThreadMessage。
线程之间传递数据并不需要什么特殊的手段,因为线程的大部分数据都是共享的,全局变量、静态全局变量和通过指针传递的数据都是可以直接在线程之间共享的。
所以最简单的方法就是定义一个全局的队列,这样每个线程都可以访问到这个队列,主线程把fd写入队列,线程池中的线程都从这个队列中取数据就可以了。当然你也可以把队列的引用通过参数传给每一个线程。
考虑到这个C++标准库的queue不是线程安全的,你可能需要用锁来保证队列的线程安全.
随便传啊,比如全局变量,堆上的内存块,只要不是
tls
线程局部存储的都可以用来传输,但前提是必须用锁控制。你可以选择互斥量等来做读写控制。
线程池接收的是一个操作,不是一个值…线程池里的线程就算已经创建了也是阻塞在队列里…只需要往线程池里投递一个带有fd的操作就可以了…
如果线程池里已经有一个操作在阻塞等待fd进来,那也会存在一个条件变量去阻塞线程运行…fd准备好了通知条件变量就可以…
Windows下可以考虑PostThreadMessage。