1.需求
1.处理一个列表的数据,要求按照列表的数据处理10个数据
 2.可以使用多线程处理,但是针对每个线程,1~10的处理顺序不能变。
 3.每个数据的处理必须原子,即只有一个线程可以针对某个数据进行处理,但是10个数据是可以由10个线程并行处理的。只是有前面的但线程内的处理顺序要求。
2.设计
设计一个处理的监控链,为每个数据定义一个线程监控的指针。
 为每个线程定义一个激活指针,如果有人需要自己激活那么就通过该指针激活等待的线程。
 比如线程1处理数据了,那么就把自己的指针设置给数据1的线程指针。
 这时候如果线程2也想处数据1,会有两种情况,如下分别处理
 情况1:数据没有任何线程锁定,那么按照线程1的方便处理数据1
 情况2:线程1正在处理数据,那么我把我的指针设置给线程1的激活指针,同时把我的指针设置给数据1的线程指针。这时候如果有线程3要处理数据1,处理的方和我的处理方法相同。
类图如下:

3.代码
#include <iostream>  
#include <thread>  
#include <queue>
#include <mutex>  
#include <condition_variable>  
#include <atomic>  
#include <windows.h>  using namespace std;
class BoxDatas; 
class MyThred;
std::mutex printmtx;//数据处理对象
class Data
{
public:int id = 0;int count = 0;
};
class BoxData
{
public:Data data;BoxData(int id){data.id = id;}MyThred* handelThread = NULL;std::mutex mtx;
};//数据容器承担多线程的处理对数据的保护功能
class BoxDatas
{
public:static BoxDatas my;static BoxDatas getMy() {return my;}static const int max = 10;BoxDatas() {for (int i = 0; i < max; i++){bs[i] = new BoxData(i);}}BoxData* bs[max];//所有数据加工只都超过10可以结束线程bool isStop() {for (size_t i = 0; i < max; i++){if (bs[i]->data.count < 10) {return false;}}return true;}
};BoxDatas BoxDatas::my = BoxDatas();//线程承载类
class MyThred
{
public:int id;std::mutex mtx;std::condition_variable cv;std::atomic_bool ready = false;MyThred* p_next = nullptr;//构造函数MyThred(int id) {this->id = id;}//数据处理函数void funBox(BoxData* boxData) {DWORD threadId = GetCurrentThreadId();//如果已经有线程占用了,那么等待std::unique_lock<std::mutex> lock(boxData->mtx);//这个锁的目标是: boxData->handelThreadif (boxData->handelThread != NULL) {std::unique_lock<std::mutex> lock2(boxData->handelThread->mtx);//这个锁的目标是:handelThread->p_nextboxData->handelThread->p_next = this;boxData->handelThread = this;//lock2.unlock();lock.unlock();//cout <<"Thread id:"<< threadId <<"  data Id:" << boxData->data.id << "  wait \n";print(boxData->data.id, "wait");cv.wait(lock2);// 无条件激活等待的线程//cv.wait(lock2, [this](){ return ready.load(); }); // 等待直到ready为true  }else{boxData->handelThread = this;lock.unlock();}//cout << "Thread id:" << threadId << "  data Id :" << boxData->data.id << " exe \n";print(boxData->data.id,"exe");//数据处理dataProcessing(boxData->data);std::unique_lock<std::mutex> lock2(mtx);//这个锁的目标是:handelThread->p_next//处理完成后需要调用等待激活的线程if (p_next != nullptr) {p_next->activeThread();}else{std::unique_lock<std::mutex> lock3(boxData->mtx);//这个锁的目标是: boxData->handelThreadboxData->handelThread = nullptr;lock3.unlock();}lock2.unlock();}//数据处理逻辑void dataProcessing(Data& data) {//加一个延时填充线程执行占用的时间//std::this_thread::sleep_for(std::chrono::seconds(5));data.count++;DWORD threadId = GetCurrentThreadId();//cout << "Thread id:" << id << "  data Id:" << data.id <<"  data value:"<< data.count << "  value \n";print(data.id,"value", data.count);}void print(int dataId,std::string funType) {DWORD threadId = GetCurrentThreadId();std::unique_lock<std::mutex> lock(printmtx);cout << "Thread id:" << threadId << "  data Id:" << dataId << "  " << funType << "\n";lock.unlock();}void print(int dataId, std::string funType,int value) {DWORD threadId = GetCurrentThreadId();std::unique_lock<std::mutex> lock(printmtx);cout << "Thread id:" << threadId << "  data Id:" << dataId << "  data value:"<< value <<"  " << funType << "\n";lock.unlock();}//此线程激活void activeThread() {ready = true;cv.notify_one(); // 唤醒一个等待在cv上的线程(如果有的话)}//线程主函数void mainThread() {while (true){for(BoxData* bd : BoxDatas::getMy().bs){funBox(bd);}//如果完成了数据,那么退出if (BoxDatas::getMy().isStop()) {break;}}}//线程运行std::thread run() {return std::thread([this] {mainThread(); });}
};//入口函数
int main() {std::thread threads[5];//线程初始化for (int i = 0; i < 5; i++){MyThred thrend(i);threads[i] = thrend.run();}//防止程序提取退出for (size_t i = 0; i < 5; i++){threads[i].join();}std::cout << "Hello from thread!\n";return 0;
}4.运行结果
Thread id:15512  data Id:0  exe
 Thread id:19512  data Id:0  wait
 Thread id:15512  data Id:0  data value:1  value
 Thread id:9320  data Id:0  wait
 Thread id:10556  data Id:0  wait
 Thread id:15512  data Id:1  exe
 Thread id:25516  data Id:0  wait
 Thread id:15512  data Id:1  data value:1  value
 Thread id:19512  data Id:0  exe
 Thread id:15512  data Id:2  exe
 Thread id:9320  data Id:0  exe
 Thread id:19512  data Id:0  data value:2  value
 Thread id:15512  data Id:2  data value:1  value
 Thread id:9320  data Id:0  data value:3  value
 Thread id:19512  data Id:1  wait
 Thread id:10556  data Id:0  exe
 Thread id:15512  data Id:3  exe
 Thread id:9320  data Id:1  wait
 Thread id:10556  data Id:0  data value:4  value
 Thread id:15512  data Id:3  data value:1  value
 Thread id:19512  data Id:1  exe
 Thread id:25516  data Id:0  exe
 Thread id:10556  data Id:1  wait
 Thread id:19512  data Id:1  data value:2  value
 Thread id:25516  data Id:0  data value:5  value
 Thread id:9320  data Id:1  exe
 Thread id:15512  data Id:4  exe
 Thread id:10556  data Id:1  exe
 Thread id:19512  data Id:2  wait
 Thread id:9320  data Id:1  data value:3  value
 Thread id:15512  data Id:4  data value:1  value
 Thread id:10556  data Id:1  data value:4  value
 Thread id:25516  data Id:1  wait
 Thread id:19512  data Id:2  exe
 Thread id:9320  data Id:2  wait
 Thread id:19512  data Id:2  data value:2  value
 Thread id:10556  data Id:2  wait
 Thread id:15512  data Id:5  exe
 Thread id:15512  data Id:5  data value:1  value
 Thread id:25516  data Id:1  exe
 Thread id:25516  data Id:1  data value:5  value
 Thread id:9320  data Id:2  exe
 Thread id:9320  data Id:2  data value:3  value
 Thread id:19512  data Id:3  wait
 Thread id:10556  data Id:2  exe
 Thread id:15512  data Id:6  exe
 Thread id:15512  data Id:6  data value:1  value
 Thread id:10556  data Id:2  data value:4  value
 Thread id:25516  data Id:2  wait
 Thread id:19512  data Id:3  exe
 Thread id:9320  data Id:3  wait
 Thread id:19512  data Id:3  data value:2  value
 Thread id:10556  data Id:3  wait
 Thread id:15512  data Id:7  exe
 Thread id:15512  data Id:7  data value:1  value
 Thread id:25516  data Id:2  exe
 Thread id:25516  data Id:2  data value:5  value
 Thread id:9320  data Id:3  exe
 Thread id:9320  data Id:3  data value:3  value
 Thread id:19512  data Id:4  wait
 Thread id:10556  data Id:3  exe
 Thread id:10556  data Id:3  data value:4  value
 Thread id:25516  data Id:3  wait
 Thread id:19512  data Id:4  exe
 Thread id:19512  data Id:4  data value:2  value
 Thread id:9320  data Id:4  wait
 Thread id:25516  data Id:3  exe
 Thread id:25516  data Id:3  data value:5  value
 Thread id:10556  data Id:4  wait
 Thread id:15512  data Id:8  exe
 Thread id:15512  data Id:8  data value:1  value
 Thread id:19512  data Id:5  wait
 Thread id:9320  data Id:4  exe
 Thread id:9320  data Id:4  data value:3  value
 Thread id:25516  data Id:4  wait
 Thread id:10556  data Id:4  exe
 Thread id:10556  data Id:4  data value:4  value
 Thread id:15512  data Id:9  exe
 Thread id:15512  data Id:9  data value:1  value
 Thread id:19512  data Id:5  exe
 Thread id:19512  data Id:5  data value:2  value
 Thread id:9320  data Id:5  wait
 Thread id:25516  data Id:4  exe
 Thread id:10556  data Id:5  wait
 Thread id:25516  data Id:4  data value:5  value
 Thread id:19512  data Id:6  wait
 Thread id:15512  data Id:0  wait
 Thread id:9320  data Id:5  exe
 Thread id:9320  data Id:5  data value:3  value
 Thread id:25516  data Id:5  wait
 Thread id:10556  data Id:5  exe
 Thread id:10556  data Id:5  data value:4  value
 Thread id:19512  data Id:6  exe
 Thread id:9320  data Id:6  wait
 Thread id:15512  data Id:0  exe
 Thread id:19512  data Id:6  data value:2  value
 Thread id:25516  data Id:5  exe
 Thread id:10556  data Id:6  wait
 Thread id:15512  data Id:0  data value:6  value
 Thread id:25516  data Id:5  data value:5  value
 Thread id:9320  data Id:6  exe
 Thread id:19512  data Id:7  wait
 Thread id:9320  data Id:6  data value:3  value
 Thread id:10556  data Id:6  exe
 Thread id:15512  data Id:1  wait
 Thread id:10556  data Id:6  data value:4  value
 Thread id:19512  data Id:7  exe
 Thread id:25516  data Id:6  wait
 Thread id:19512  data Id:7  data value:2  value
 Thread id:15512  data Id:1  exe
 Thread id:9320  data Id:7  wait
 Thread id:15512  data Id:1  data value:6  value
 Thread id:25516  data Id:6  exe
 Thread id:25516  data Id:6  data value:5  value
 Thread id:10556  data Id:7  wait
 Thread id:9320  data Id:7  exe
 Thread id:19512  data Id:8  wait
 Thread id:9320  data Id:7  data value:3  value
 Thread id:25516  data Id:7  wait
 Thread id:15512  data Id:2  wait
 Thread id:10556  data Id:7  exe
 Thread id:10556  data Id:7  data value:4  value
 Thread id:9320  data Id:8  wait
 Thread id:19512  data Id:8  exe
 Thread id:19512  data Id:8  data value:2  value
 Thread id:25516  data Id:7  exe
 Thread id:25516  data Id:7  data value:5  value
 Thread id:15512  data Id:2  exe
 Thread id:15512  data Id:2  data value:6  value
 Thread id:10556  data Id:8  wait
 Thread id:9320  data Id:8  exe
 Thread id:9320  data Id:8  data value:3  value
 Thread id:19512  data Id:9  wait
 Thread id:15512  data Id:3  wait
 Thread id:25516  data Id:8  wait
 Thread id:19512  data Id:9  exe
 Thread id:19512  data Id:9  data value:2  value
 Thread id:15512  data Id:3  exe
 Thread id:9320  data Id:9  wait
 Thread id:10556  data Id:8  exe
 Thread id:10556  data Id:8  data value:4  value
 Thread id:25516  data Id:8  exe
 Thread id:19512  data Id:0  wait
 Thread id:15512  data Id:3  data value:6  value
 Thread id:25516  data Id:8  data value:5  value
 Thread id:9320  data Id:9  exe
 Thread id:10556  data Id:9  wait
 Thread id:9320  data Id:9  data value:3  value
 Thread id:19512  data Id:0  exe
 Thread id:19512  data Id:0  data value:7  value
 Thread id:15512  data Id:4  wait
 Thread id:10556  data Id:9  exe
 Thread id:25516  data Id:9  wait
 Thread id:10556  data Id:9  data value:4  value
 Thread id:19512  data Id:1  wait
 Thread id:9320  data Id:0  wait
 Thread id:15512  data Id:4  exe
 Thread id:15512  data Id:4  data value:6  value
 Thread id:10556  data Id:0  wait
 Thread id:25516  data Id:9  exe
 Thread id:9320  data Id:0  exe
 Thread id:19512  data Id:1  exe
 Thread id:19512  data Id:1  data value:7  value
 Thread id:25516  data Id:9  data value:5  value
 Thread id:9320  data Id:0  data value:8  value
 Thread id:15512  data Id:5  wait
 Thread id:10556  data Id:0  exe
 Thread id:10556  data Id:0  data value:9  value
 Thread id:19512  data Id:2  wait
 Thread id:9320  data Id:1  wait
 Thread id:25516  data Id:0  wait
 Thread id:19512  data Id:2  exe
 Thread id:15512  data Id:5  exe
 Thread id:9320  data Id:1  exe
 Thread id:10556  data Id:1  wait
 Thread id:19512  data Id:2  data value:7  value
 Thread id:15512  data Id:5  data value:6  value
 Thread id:9320  data Id:1  data value:8  value
 Thread id:25516  data Id:0  exe
 Thread id:25516  data Id:0  data value:10  value
 Thread id:19512  data Id:3  wait
 Thread id:10556  data Id:1  exe
 Thread id:10556  data Id:1  data value:9  value
 Thread id:15512  data Id:6  wait
 Thread id:25516  data Id:1  wait
 Thread id:9320  data Id:2  wait
 Thread id:15512  data Id:6  exe
 Thread id:15512  data Id:6  data value:6  value
 Thread id:25516  data Id:1  exe
 Thread id:25516  data Id:1  data value:10  value
 Thread id:19512  data Id:3  exe
 Thread id:10556  data Id:2  wait
 Thread id:19512  data Id:3  data value:7  value
 Thread id:9320  data Id:2  exe
 Thread id:15512  data Id:7  wait
 Thread id:9320  data Id:2  data value:8  value
 Thread id:10556  data Id:2  exe
 Thread id:25516  data Id:2  wait
 Thread id:10556  data Id:2  data value:9  value
 Thread id:15512  data Id:7  exe
 Thread id:19512  data Id:4  wait
 Thread id:15512  data Id:7  data value:6  value
 Thread id:25516  data Id:2  exe
 Thread id:25516  data Id:2  data value:10  value
 Thread id:9320  data Id:3  wait
 Thread id:19512  data Id:4  exe
 Thread id:10556  data Id:3  wait
 Thread id:19512  data Id:4  data value:7  value
 Thread id:25516  data Id:3  wait
 Thread id:15512  data Id:8  wait
 Thread id:9320  data Id:3  exe
 Thread id:9320  data Id:3  data value:8  value
 Thread id:19512  data Id:5  wait
 Thread id:10556  data Id:3  exe
 Thread id:15512  data Id:8  exe
 Thread id:25516  data Id:3  exe
 Thread id:9320  data Id:4  wait
 Thread id:10556  data Id:3  data value:9  value
 Thread id:10556  data Id:4  wait
 Thread id:25516  data Id:3  data value:10  value
 Thread id:19512  data Id:5  exe
 Thread id:15512  data Id:8  data value:6  value
 Thread id:9320  data Id:4  exe
 Thread id:9320  data Id:4  data value:8  value
 Thread id:19512  data Id:5  data value:7  value
 Thread id:25516  data Id:4  wait
 Thread id:10556  data Id:4  exe
 Thread id:15512  data Id:9  wait
 Thread id:10556  data Id:4  data value:9  value
 Thread id:19512  data Id:6  wait
 Thread id:9320  data Id:5  wait
 Thread id:25516  data Id:4  exe
 Thread id:10556  data Id:5  wait
 Thread id:25516  data Id:4  data value:10  value
 Thread id:15512  data Id:9  exe
 Thread id:15512  data Id:9  data value:6  value
 Thread id:19512  data Id:6  exe
 Thread id:25516  data Id:5  wait
 Thread id:9320  data Id:5  exe
 Thread id:9320  data Id:5  data value:8  value
 Thread id:10556  data Id:5  exe
 Thread id:10556  data Id:5  data value:9  value
 Thread id:19512  data Id:6  data value:7  value
 Thread id:15512  data Id:0  wait
 Thread id:25516  data Id:5  exe
 Thread id:9320  data Id:6  wait
 Thread id:25516  data Id:5  data value:10  value
 Thread id:19512  data Id:7  wait
 Thread id:10556  data Id:6  wait
 Thread id:15512  data Id:0  exe
 Thread id:15512  data Id:0  data value:11  value
 Thread id:25516  data Id:6  wait
 Thread id:9320  data Id:6  exe
 Thread id:9320  data Id:6  data value:8  value
 Thread id:19512  data Id:7  exe
 Thread id:19512  data Id:7  data value:7  value
 Thread id:10556  data Id:6  exe
 Thread id:10556  data Id:6  data value:9  value
 Thread id:15512  data Id:1  wait
 Thread id:25516  data Id:6  exe
 Thread id:25516  data Id:6  data value:10  value
 Thread id:9320  data Id:7  wait
 Thread id:10556  data Id:7  wait
 Thread id:19512  data Id:8  wait
 Thread id:9320  data Id:7  exe
 Thread id:9320  data Id:7  data value:8  value
 Thread id:10556  data Id:7  exe
 Thread id:25516  data Id:7  wait
 Thread id:15512  data Id:1  exe
 Thread id:15512  data Id:1  data value:11  value
 Thread id:19512  data Id:8  exe
 Thread id:19512  data Id:8  data value:7  value
 Thread id:10556  data Id:7  data value:9  value
 Thread id:9320  data Id:8  wait
 Thread id:25516  data Id:7  exe
 Thread id:15512  data Id:2  wait
 Thread id:25516  data Id:7  data value:10  value
 Thread id:10556  data Id:8  wait
 Thread id:19512  data Id:9  wait
 Thread id:9320  data Id:8  exe
 Thread id:9320  data Id:8  data value:8  value
 Thread id:25516  data Id:8  wait
 Thread id:15512  data Id:2  exe
 Thread id:15512  data Id:2  data value:11  value
 Thread id:10556  data Id:8  exe
 Thread id:10556  data Id:8  data value:9  value
 Thread id:19512  data Id:9  exe
 Thread id:19512  data Id:9  data value:7  value
 Thread id:9320  data Id:9  wait
 Thread id:25516  data Id:8  exe
 Thread id:25516  data Id:8  data value:10  value
 Thread id:15512  data Id:3  wait
 Thread id:19512  data Id:0  wait
 Thread id:10556  data Id:9  wait
 Thread id:15512  data Id:3  exe
 Thread id:15512  data Id:3  data value:11  value
 Thread id:19512  data Id:0  exe
 Thread id:19512  data Id:0  data value:12  value
 Thread id:9320  data Id:9  exe
 Thread id:9320  data Id:9  data value:8  value
 Thread id:25516  data Id:9  wait
 Thread id:10556  data Id:9  exe
 Thread id:10556  data Id:9  data value:9  value
 Thread id:15512  data Id:4  wait
 Thread id:9320  data Id:0  wait
 Thread id:19512  data Id:1  wait
 Thread id:15512  data Id:4  exe
 Thread id:15512  data Id:4  data value:11  value
 Thread id:9320  data Id:0  exe
 Thread id:9320  data Id:0  data value:13  value
 Thread id:25516  data Id:9  exe
 Thread id:25516  data Id:9  data value:10  value
 Thread id:10556  data Id:0  wait
 Thread id:19512  data Id:1  exe
 Thread id:19512  data Id:1  data value:12  value
 Thread id:15512  data Id:5  wait
 Thread id:10556  data Id:0  exe
 Thread id:10556  data Id:0  data value:14  value
 Thread id:9320  data Id:1  wait
 Thread id:15512  data Id:5  exe
 Thread id:15512  data Id:5  data value:11  value
 Thread id:19512  data Id:2  wait
 Thread id:9320  data Id:1  exe
 Thread id:9320  data Id:1  data value:13  value
 Thread id:10556  data Id:1  wait
 Thread id:19512  data Id:2  exe
 Thread id:19512  data Id:2  data value:12  value
 Thread id:15512  data Id:6  wait
 Thread id:10556  data Id:1  exe
 Thread id:10556  data Id:1  data value:14  value
 Thread id:9320  data Id:2  wait
 Thread id:15512  data Id:6  exe
 Thread id:15512  data Id:6  data value:11  value
 Thread id:19512  data Id:3  wait
 Thread id:9320  data Id:2  exe
 Thread id:9320  data Id:2  data value:13  value
 Thread id:10556  data Id:2  wait
 Thread id:19512  data Id:3  exe
 Thread id:19512  data Id:3  data value:12  value
 Thread id:15512  data Id:7  wait
 Thread id:10556  data Id:2  exe
 Thread id:10556  data Id:2  data value:14  value
 Thread id:9320  data Id:3  wait
 Thread id:15512  data Id:7  exe
 Thread id:15512  data Id:7  data value:11  value
 Thread id:19512  data Id:4  wait
 Thread id:9320  data Id:3  exe
 Thread id:9320  data Id:3  data value:13  value
 Thread id:10556  data Id:3  wait
 Thread id:19512  data Id:4  exe
 Thread id:19512  data Id:4  data value:12  value
 Thread id:15512  data Id:8  wait
 Thread id:10556  data Id:3  exe
 Thread id:10556  data Id:3  data value:14  value
 Thread id:9320  data Id:4  wait
 Thread id:15512  data Id:8  exe
 Thread id:15512  data Id:8  data value:11  value
 Thread id:19512  data Id:5  wait
 Thread id:9320  data Id:4  exe
 Thread id:9320  data Id:4  data value:13  value
 Thread id:10556  data Id:4  wait
 Thread id:19512  data Id:5  exe
 Thread id:19512  data Id:5  data value:12  value
 Thread id:15512  data Id:9  wait
 Thread id:10556  data Id:4  exe
 Thread id:10556  data Id:4  data value:14  value
 Thread id:9320  data Id:5  wait
 Thread id:15512  data Id:9  exe
 Thread id:15512  data Id:9  data value:11  value
 Thread id:19512  data Id:6  wait
 Thread id:9320  data Id:5  exe
 Thread id:9320  data Id:5  data value:13  value
 Thread id:10556  data Id:5  wait
 Thread id:19512  data Id:6  exe
 Thread id:19512  data Id:6  data value:12  value
 Thread id:9320  data Id:6  wait
 Thread id:10556  data Id:5  exe
 Thread id:10556  data Id:5  data value:14  value
 Thread id:19512  data Id:7  wait
 Thread id:9320  data Id:6  exe
 Thread id:10556  data Id:6  wait
 Thread id:9320  data Id:6  data value:13  value
 Thread id:19512  data Id:7  exe
 Thread id:19512  data Id:7  data value:12  value
 Thread id:9320  data Id:7  wait
 Thread id:10556  data Id:6  exe
 Thread id:10556  data Id:6  data value:14  value
 Thread id:19512  data Id:8  wait
 Thread id:9320  data Id:7  exe
 Thread id:9320  data Id:7  data value:13  value
 Thread id:10556  data Id:7  wait
 Thread id:19512  data Id:8  exe
 Thread id:19512  data Id:8  data value:12  value
 Thread id:9320  data Id:8  wait
 Thread id:10556  data Id:7  exe
 Thread id:10556  data Id:7  data value:14  value
 Thread id:19512  data Id:9  wait
 Thread id:9320  data Id:8  exe
 Thread id:9320  data Id:8  data value:13  value
 Thread id:10556  data Id:8  wait
 Thread id:19512  data Id:9  exe
 Thread id:19512  data Id:9  data value:12  value
 Thread id:9320  data Id:9  wait
 Thread id:10556  data Id:8  exe
 Thread id:10556  data Id:8  data value:14  value
 Thread id:10556  data Id:9  wait
 Thread id:9320  data Id:9  exe
 Thread id:9320  data Id:9  data value:13  value
 Thread id:10556  data Id:9  exe
 Thread id:10556  data Id:9  data value:14  value
 Hello from thread!