码迷,mamicode.com
首页 > 编程语言 > 详细

多线程编程之无锁队列

时间:2017-12-08 21:03:28      阅读:227      评论:0      收藏:0      [点我收藏+]

标签:queue   error   false   取数据   小结   计算   添加   lshell   没有   

关于无锁队列的概念与实现,可以参考博文《无锁队列的实现》,主要涉及到的知识点包括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只有在计算结束之前的时候才能进行自增运算

多线程编程之无锁队列

标签:queue   error   false   取数据   小结   计算   添加   lshell   没有   

原文地址:http://www.cnblogs.com/cyyljw/p/8006855.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!