C++ 线程以及队列简例

古城微笑少年丶 2023-01-01 15:52 116阅读 0赞

# 1.实现  #

线程1 不停的插入随机数入队

线程2 每隔10ms 弹出队首部数据

# 2.g++编译 #

注意加上 -lpthread

g++ -o test q.cpp -lpthread

# 3. android-ndk-10e编译 #

注意加上 -std=c++11

/home/hil/android-ndk-r10e/android_standlone_toolchain/bin/arm-linux-androideabi-g++ -fPIE -pie -o ttransfer  /home/hil/VTD.2.2/rdbSend/M2MAPI/Main/TTransfer/main.cpp -I /home/hil/VTD.2.2/rdbSend/M2MAPI/Include/ -ldl ../../Library/libm2mapi.so -std=c++11

# 4.demo  #

/*
    
     * @Description: 
    
     * @Version: 
    
     * @Autor: zolty
    
     * @Date: 2021-01-02 21:15:20
    
     * @LastEditors: zolty
    
     * @LastEditTime: 2021-01-03 19:38:00
    
     */
    
    #include <iostream>
    
    #include <thread>
    
    #include <unistd.h>
    
    #include <sys/time.h>
    
    #include <queue>
    
    using namespace std;
    
    queue<int> q;
    
    
    
    long getTimestamp()//获取时间戳
    
    {
    
        struct timeval tv;
    
        gettimeofday(&tv, NULL);
    
        return tv.tv_sec * 1000 + tv.tv_usec / 1000;
    
    }
    
    
    
    void t1() // 不停的插入随机数 入队
    
    {
    
        while (1)
    
        {
    
            q.push(rand());
    
        }
    
    }
    
    
    
    void t2() // 每隔10ms 发送一次队首数据 出队
    
    {
    
        while (1)
    
        {
    
            while (!q.empty())//队非空
    
            {
    
                sleep(0.1);
    
                cout << "timeStamp: "<< getTimestamp() <<" qSize: "<<q.size()<< " qFront: " << q.front() << endl;
    
                q.pop();
    
            }
    
        }
    
    }
    
    
    
    int main()
    
    {
    
        thread th1(t1);
    
        thread th2(t2);
    
        th1.join(); //等待th1执行完
    
        th2.join(); //等待th2执行完
    
        return 0;
    
    }