#include <iostream>
#include "tbb/concurrent_priority_queue.h"
#include <thread>
using namespace std;
void worker1();
void worker2();
void worker3();
void consumer();
tbb::concurrent_priority_queue<int> pq;
int main(){
thread t1(worker1);
t1.detach();
thread t2(worker2);
t2.detach();
thread t3(worker3);
t3.detach();
thread t4(consumer);
t4.detach();
while(true);
}
void worker1(){
for(int i=0;i<1000;++i){
pq.push(i);
}
}
void worker2(){
for(int i=5000;i<6000;++i)
pq.push(i);
}
void worker3(){
for(int i=8000;i<9000;++i)
pq.push(i);
}
void consumer(){
int i;
while(pq.try_pop(i))
cout<<i<<endl;
}
result:
8759
8763
8808
8809
8807
8806
8805
8823
8824
8825
8822
8821
8826
8820
……
……
17
16
15
14
13
12
11
10
9
8
7
6
5
4
3
2
1
0
