- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我想使用 C++11 实现一个线程池。它是一个模板类,由一个工作队列、一个工作函数和一个线程 vector 组成。这是我的 h 文件
#ifndef THREADPOOL_H
#define THREADPOOL_H
#include <vector>
#include <list>
#include <memory>
#include <thread>
#include <mutex>
#include <condition_variable>
// a threadpool with template
template<typename T>
class threadpool {
public:
threadpool(int thread_num, int request_num);
bool add_requests(T* request);
void run();
~threadpool();
private:
//the vector of multiple thread
std::vector<std::thread> threads;
// the task queue
std::list<T*> work_queue;
//synchronization
std::mutex queue_mutex;
std::condition_variable condition;
int max_requests;
bool stop;
};
//the worker function
template<typename T>
void threadpool<T>::run() {
while (1) {
T* request;
{
std::unique_lock<std::mutex> lock(this->queue_mutex);
condition.wait(lock, [this] {return !(this->work_queue.empty()); });
if (this->stop&&this->work_queue.empty())
return;
request = work_queue.front();
work_queue.pop_front();
}
request->process();
}
}
//add new work item to the pool
template<typename T>
bool threadpool<T>::add_requests(T* request) {
std::unique_lock<std::mutex> lock(this->queue_mutex);
if (work_queue.size() >= max_requests)
return false;
work_queue.push_back(request);
condition.notify_one();
return true;
}
// the constructor
template<typename T>
inline threadpool<T>::threadpool(int thread_num, int request_num) :max_requests(request_num), stop(false) {
for (int i = 0; i < thread_num; ++i)
threads.emplace_back(&threadpool::run, this);
}
// the destructor joins all threads
template<typename T>
inline threadpool<T>::~threadpool()
{
{
std::unique_lock<std::mutex> lock(queue_mutex);
stop = true;
}
condition.notify_all();
//there is an error, the thread never stops...
for (std::thread &worker: threads)
worker.join();
}
#endif
而我的测试代码如下。有一些错误。我的 thread.join() 似乎出现了死锁,谁能告诉我为什么?
//for test my thread pool
#include"threadpool.h"
#include<iostream>
#include<ctime>
#include <windows.h>
struct node {
static int cur;
void process(){
++cur;
std::cout << cur << std::endl;
Sleep(2000);
}
};
int node::cur = 10;
int main()
{
threadpool<node> haha(4, 5);
clock_t start;
clock_t end;
node a1;
node a2;
node a3;
//start = clock();
//add request
haha.add_requests(&a1);
haha.add_requests(&a2);
haha.add_requests(&a3);
return 0;
}
最佳答案
当你在析构函数中将 stop
设置为 true
时,你的条件变量谓词可能不会中断等待,因此你也应该在内部检查 stop
:
condition.wait(lock, [this] {return this->stop || !(this->work_queue.empty()); });
关于c++ - 为什么我的线程永远不会结束,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45135718/
我正在编写一个类,我想知道哪一对方法更适合描述流程周期: start() -> stop() start() -> end() start() -> finish() 基本上这些方法将在执行任务之前和
对于 Android 小部件类名称是否应以“View”、“Layout”或两者都不结尾,是否存在模式或命名约定? 最佳答案 如果该类扩展了 View(或在其层次结构中扩展了 View),那么它应该以“
我正在尝试找到一个插件,该插件将使用 Verilog 突出显示匹配的开始/结束语句。 VIM 让它与花括号/括号一起工作,但它不能与它的开始/结束一起工作。我希望 VIM 突出显示正确的开始到正确的结
给出以下代码: % Generate some random data n = 10; A = cell(n, 1); for i=1:n A{i} = timeseries; A{i
我需要知道是否可以检测输入何时开始聚焦以及何时结束焦点 HTML 代码: JQuery 代码(仅示例我如何需要它): $('.datas').on('focusStart', alert("fo
所以我一直在思考一款游戏的想法,一款需要穿越时空的游戏。因此,我编写了一个 JFrame 来显示螺旋的 .gif,但它并没有在对话框显示时结束,而是保留在后台。我可以解决这个问题吗? import j
给出以下使用多线程的 Java 示例: import java.util.concurrent.*; public class SquareCalculator { private Ex
好吧,我有一个 do-while 循环,应该在使用点击“q”时结束,但它给了我错误消息,请帮忙。 package Assignments; import java.util.*; public cla
我如何有选择地匹配开始 ^或结束 $正则表达式中的一行? 例如: /(?\\1', $str); 我的字符串开头和结尾处的粗体边缘情况没有被匹配。我在使用其他变体时遇到的一些极端情况包括字符串内匹配、
我试图让程序在总数达到 10 时结束,但由于某种原因,我的 while 循环在达到 10 时继续计数。一旦回答了 10 个问题,我就有 int 百分比来查找百分比。 import java.util.
jQuery 中的 end() 函数将元素集恢复到上次破坏性更改之前的状态,因此我可以看到它应该如何使用,但我已经看到了一些代码示例,例如:on alistapart (可能来自旧版本的 jQuery
这个问题在这里已经有了答案: How to check if a string "StartsWith" another string? (18 个答案) 关闭 9 年前。 var file =
我正在尝试在 travis 上设置两个数据库,但它只是在 before_install 声明的中途停止: (END) No output has been received in the last 1
我创建了一个简单的存储过程,它循环遍历一个表的行并将它们插入到另一个表中。由于某种原因,END WHILE 循环抛出缺少分号错误。所有代码对我来说都是正确的,并且所有分隔符都设置正确。我只是不明白为什
您好,我正在使用 AVSpeechSynthesizer 和 AVSpeechUtterance 构建一个 iOS 7 应用程序,我想弄清楚合成何时完成。更具体地说,我想在合成结束时更改播放/暂停按钮
这是我的代码,我试图在响应后显示警报。但没有显示操作系统警报 string filepath = ConfigurationManager.AppSettings["USPPath"].ToStri
我想创建一个循环,在提供的时间段、第一天和最后一天返回每个月(考虑到月份在第 28-31 天结束):(“function_to_increase_month”尚未定义) for beg in pd.d
我目前正在用 Python 3.6 为一个骰子游戏编写代码,我知道我的编码在这方面有点不对劲,但是,我真的只是想知道如何开始我的 while 循环。游戏说明如下…… 人类玩家与计算机对战。 玩家 1
所以我已经了解了如何打开 fragment。这是我的困境。我的 view 旁边有一个元素列表(元素周期表元素)。当您选择一个元素时,它会显示它的信息。 我的问题是我需要能够从(我们称之为详细信息 fr
我想检测用户何时停止滚动页面/元素。这可能很棘手,因为最近对 OSX 滚动行为的增强创造了这种新的惯性效应。是否触发了事件? 我能想到的唯一其他解决方案是在页面/元素的滚动位置不再改变时使用间隔来拾取
我是一名优秀的程序员,十分优秀!