多线程编程之无锁队列

Posted 拙园

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了多线程编程之无锁队列相关的知识,希望对你有一定的参考价值。

关于无锁队列的概念与实现,可以参考博文《无锁队列的实现》,主要涉及到的知识点包括CAS原子操作、无锁队列的链表实现、无锁队列的数组实现以及ABA问题。

  下面借鉴了《多线程的那点儿事(之无锁队列)》的代码,说明两个线程(一个添加一个读取数据)之间的无锁队列,可以不借助线程互斥方法就能够达到并行效果。代码如下:

#define MAX_NUMBER 1000L
#define STATUS int
#define OK     0
#define FALSE -1

typedef struct _QUEUE_DATA
{
    int data[MAX_NUMBER];
    int head;
    int tail;
}QUEUE_DATA; 

STATUS push_data(QUEUE_DATA* pQueue, int data)
{
    if(NULL == pQueue)
        return ERROR;

    if(pQueue->head == ((pQueue->tail) + 1)% MAX_NUMBER)
        return ERROR;

    pQueue->data[pQueue->tail] = data;
    pQueue->tail = (pQueue->tail + 1)% MAX_NUMBER;
    return OK;
}

STATUS pop_data(QUEUE_DATA* pQueue, int* pData)
{
    if(NULL == pQueue || NULL == pData)
        return ERROR;

    if(pQueue->head == pQueue->tail)
        return ERROR;

    *pData = pQueue->data[pQueue->head];
    pQueue->head = (pQueue->head + 1)% MAX_NUMBER;
    return OK;
}

  

小结:

  1. 无锁队列只适合两个线程并行使用,一个压入数据,一个弹出数据
  2. 无锁队列是没有锁的并行,没有死锁的危险
  3. 无锁队列中head和tail只有在计算结束之前的时候才能进行自增运算

以上是关于多线程编程之无锁队列的主要内容,如果未能解决你的问题,请参考以下文章

并发编程(学习笔记-共享模型之无锁)-part5

交易系统开发技能及面试之无锁编程(Lock-free)

无锁队列的实现

Java高并发之无锁与Atomic源码分析

(转)高效线程池之无锁化实现(Linux C)

C++ 无锁队列与多线程崩溃