当前位置: 技术问答>linux和unix
关于多线程编程的条件变量问题
来源: 互联网 发布时间:2016-09-29
本文导语: 我最近想设计一个线程池,池里面创建n个线程,每个线程都等待条件变量触发然后执行用户行为函数;当增加一个用户行为函数时,触发条件变量,其中一个等待的线程将被唤醒,执行用户代码。 问题来了:如果现...
我最近想设计一个线程池,池里面创建n个线程,每个线程都等待条件变量触发然后执行用户行为函数;当增加一个用户行为函数时,触发条件变量,其中一个等待的线程将被唤醒,执行用户代码。
问题来了:如果现在这n个线程都在执行任务。但新的用户任务加入了,此时唤醒条件变量,但没有任何线程在等待该条件,那直到有线程完成了自身的任务后,这个新加入的任务最终能被执行么?
问题来了:如果现在这n个线程都在执行任务。但新的用户任务加入了,此时唤醒条件变量,但没有任何线程在等待该条件,那直到有线程完成了自身的任务后,这个新加入的任务最终能被执行么?
|
可参考glib2的线程池实现。
|
唤醒一个条件变量时,如果没有相应的线程在等待该条件变量,这次唤醒将被丢失.....所以新加入的任务很有可能不被执行。
做线程池的时候,通常是管理线程从空闲线程列表里面选择一个空闲进程进行唤醒,如果当前没有空闲进程,当前请求用户应该是处于阻塞状态。
做线程池的时候,通常是管理线程从空闲线程列表里面选择一个空闲进程进行唤醒,如果当前没有空闲进程,当前请求用户应该是处于阻塞状态。
|
你刚好搞反了, 另外用条件变量也不合适, 应该用信号量, 每收到一个任务,消费一个信号量,线程池里的线程每完成一个任务,产生一个信号量. 当前没有空闲线程时,你获取不到信号量,收到的任务将被阻塞
|
这个得看你的线程池是设计成固定大小的呢
还是可以动态增加的
你在threadpool里面增加一个变量 表示当前的activethreadsnumber
据此来做判断
还是可以动态增加的
你在threadpool里面增加一个变量 表示当前的activethreadsnumber
据此来做判断