tbb/concurrent_priority_queue example

#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