有问题的线程必须有一些线程本地数据(在构造时初始化)并将循环工作项,直到满足某些条件.

伪代码：

volatile bool run = true;
 
int WorkerThread(param)
{
    localclassinstance c1 = new c1();
    [other initialization]
 
    while(true) {
        [LOCK]
        [unqueue work item]
        [UNLOCK]
        if([hasWorkItem]) {
            [process data]
            [PostMessage with pointer to data]
        }
        [Sleep]
 
        if(!run)
            break;
    }
 
    [uninitialize]
    return 0;
}

我想我会通过关键部分进行锁定,因为队列将是std :: vector或std :: queue,但也许有更好的方法.

具有睡眠功能的部件看起来并不太好,因为睡眠值很大时会有很多额外的睡眠,或者睡眠值很小时需要额外锁定,这绝对没有必要.

但我想不出我可以使用的WaitForSingleObject友好原语而不是临界区,因为可能有两个线程同时排队工作项.因此,事件似乎是最佳候选者,如果已经设置了事件,则可以松开第二个工作项,并且它不能保证互斥.

也许甚至有一种更好的方法使用InterlockedExchange类型的函数可以减少序列化.

P.S.：我可能需要预先处理整个队列并在出队前阶段删除过时的工作项.