c++ 多线程 队列 顺序取出数据
菜鸟实现耗时测试，勿喷
#include <iostream>
#include <queue>
#include <thread>
#include <mutex>
#include <unistd.h>
#include <semaphore.h>
using namespace std;
#define msleep(x) usleep(x*1000)
queue<int> queueIn;
queue<int> queueOut;
std::mutex threadMutex;
int max_len = 4;
int index = 0;
static sem_t g_semaphore;
static sem_t g_semaphore_queuOut;
bool isEnd = false;
void decoder() {
int i = 0;
while (i < 10000) {
if(queueIn.size() > max_len) {
continue;
}
queueIn.push(i++);
}
while (index != 9999) {
}
isEnd = true;
}
void encoder() {
int i = -1;
while (!isEnd || !queueIn.empty()) {
i = -1;
sem_wait(&g_semaphore);
if(!queueIn.empty()){
i = queueIn.front();
queueIn.pop();
}
sem_post(&g_semaphore);
if(i == -1){
continue;
}
while (true){
if(i == 0){
break;
}
//printf("index %d i %d\n",index,i);
if(i - index == 1){
break;
}
}
sem_wait(&g_semaphore_queuOut);
queueOut.push(i);
if(i > index) {
index = i;
}
sem_post(&g_semaphore_queuOut);
}
}
void enCoderH264() {
while (!isEnd || !queueOut.empty() || !queueIn.empty()) {
sem_wait(&g_semaphore_queuOut);
if(!queueOut.empty()){
int i = queueOut.front();
queueOut.pop();
printf("queueout %d \n",i);
}
sem_post(&g_semaphore_queuOut);
}
//printf("end %d \n",queueOut.size());
}
int main() {
sem_init(&g_semaphore, 0, 1);
sem_init(&g_semaphore_queuOut,0,1);
thread t(decoder);
thread t2(encoder);
thread t3(encoder);
thread t4(encoder);
thread t5(enCoderH264);
t.detach();
t2.detach();
t3.detach();
t4.detach();
t5.detach();
std::cout << "Hello, World!" << std::endl;
pthread_exit(NULL);
return 0;
}
