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

}

sem_init：初始化信号量sem_t，初始化的时候可以指定信号量的初始值，以及是否可以在多进程间共享。

sem_wait：一直阻塞等待直到信号量>0。

sem_timedwait：阻塞等待若干时间直到信号量>0。

sem_post：使信号量加1。

sem_destroy：释放信号量。和sem_init对应。 答案补充 关于各函数的具体参数请用man查看,如man sem_init可查看该函数的帮助

sem_init：初始化信号量sem_t初始化候指定信号量初始值及否进程间共享

sem_wait：直阻塞等待直信号量>0

sem_timedwait：阻塞等待若干间直信号量>0

sem_post：使信号量加1

sem_destroy：释放信号量sem_init应 答案补充 关于各函数具体参数请用man查看,man sem_init查看该函数帮助

---