程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> C語言 >> C >> 關於C >> c 實現的 循環隊列

c 實現的 循環隊列

編輯:關於C

//
//  fs_loop_queue.h
//  fsnet
//
//  Created by Vincent on 14-5-22.
//  Copyright (c) 2014年 Vincent. All rights reserved.
//

#ifndef fsnet_fs_loop_queue_h
#define fsnet_fs_loop_queue_h

#include "fs_define.h"

struct fs_loop_queue;


struct fs_loop_queue* fs_create_loop_queue(size_t len);

fs_bool fs_loop_queue_push(struct fs_loop_queue*, void* item);
void*   fs_loop_queue_pop(struct fs_loop_queue*);

fs_bool fs_loop_queue_full(struct fs_loop_queue*);
fs_bool fs_loop_queue_empty(struct fs_loop_queue*);

void fs_loop_queue_free( struct fs_loop_queue* );

#endif

//
//  fs_loop_queue.c
//  fsnet
//
//  Created by Vincent on 14-5-22.
//  Copyright (c) 2014年 Vincent. All rights reserved.
//

#include 
#include "fs_loop_queue.h"
#include "fs_malloc.h"


struct fs_loop_queue{
    
    void** que;
    size_t head;
    size_t tail;
    size_t max_len;
    
    unsigned long script_id;
};


#define _pos_add(x, n, max) x = (x + n) % max

struct fs_loop_queue*
fs_create_loop_queue(size_t len){
    struct fs_loop_queue* queue = (struct fs_loop_queue*)fs_malloc(sizeof(*queue));
    fs_zero(queue, sizeof(*queue));
    queue->max_len = len;
    queue->que = fs_malloc( sizeof( void* ) * len );
    fs_zero(queue->que, sizeof( void* ) * len);
    return queue;
}

fs_bool
fs_loop_queue_push( struct fs_loop_queue* que, void* item){

    if(fs_loop_queue_full(que)){
        return fs_false;
    }
    
    que->que[que->head] = item;
    _pos_add(que->head, 1, que->max_len);
    
    
    return fs_true;
}

void*
fs_loop_queue_pop( struct fs_loop_queue* que ){

    if(fs_loop_queue_empty(que)){
        return NULL;
    }
    
    
    void* item = que->que[que->tail];
    que->que[que->tail] = NULL;
    _pos_add(que->tail, 1, que->max_len);
    
    return item;
    
}

fs_bool
fs_loop_queue_full( struct fs_loop_queue* que ){

    return ((que->head + 1) % que->max_len) == que->tail;
}

fs_bool
fs_loop_queue_empty( struct fs_loop_queue* que ){
    
    return que->head == que->tail;
}


void
fs_loop_queue_free( struct fs_loop_queue* que){
    
    fs_free(que->que);
    fs_free(que);
    
}

這種循環隊列, 在 A push B pop 是無鎖的.

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved