mono/utils/lock-free-queue.h

   1 /*
   2  * lock-free-queue.h: Lock free queue.
   3  *
   4  * (C) Copyright 2011 Novell, Inc
   5  *
   6  *
   7  * Permission is hereby granted, free of charge, to any person obtaining
   8  * a copy of this software and associated documentation files (the
   9  * "Software"), to deal in the Software without restriction, including
  10  * without limitation the rights to use, copy, modify, merge, publish,
  11  * distribute, sublicense, and/or sell copies of the Software, and to
  12  * permit persons to whom the Software is furnished to do so, subject to
  13  * the following conditions:
  14  *
  15  * The above copyright notice and this permission notice shall be
  16  * included in all copies or substantial portions of the Software.
  17  *
  18  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  19  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  20  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  21  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  22  * LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  23  * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  24  * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  25  */
  26
  27
  28 #ifndef __MONO_LOCKFREEQUEUE_H__
  29 #define __MONO_LOCKFREEQUEUE_H__
  30
  31 #include <glib.h>
  32
  33 //#define QUEUE_DEBUG   1
  34
  35 typedef struct _MonoLockFreeQueueNode MonoLockFreeQueueNode;
  36
  37 struct _MonoLockFreeQueueNode {
  38         MonoLockFreeQueueNode * volatile next;
  39 #ifdef QUEUE_DEBUG
  40         gint32 in_queue;
  41 #endif
  42 };
  43
  44 typedef struct {
  45         MonoLockFreeQueueNode node;
  46         volatile gint32 in_use;
  47 } MonoLockFreeQueueDummy;
  48
  49 #define MONO_LOCK_FREE_QUEUE_NUM_DUMMIES        2
  50
  51 typedef struct {
  52         MonoLockFreeQueueNode * volatile head;
  53         MonoLockFreeQueueNode * volatile tail;
  54         MonoLockFreeQueueDummy dummies [MONO_LOCK_FREE_QUEUE_NUM_DUMMIES];
  55         volatile gint32 has_dummy;
  56 } MonoLockFreeQueue;
  57
  58 void mono_lock_free_queue_init (MonoLockFreeQueue *q) MONO_INTERNAL;
  59
  60 void mono_lock_free_queue_node_init (MonoLockFreeQueueNode *node, gboolean to_be_freed) MONO_INTERNAL;
  61 void mono_lock_free_queue_node_free (MonoLockFreeQueueNode *node) MONO_INTERNAL;
  62
  63 void mono_lock_free_queue_enqueue (MonoLockFreeQueue *q, MonoLockFreeQueueNode *node) MONO_INTERNAL;
  64
  65 MonoLockFreeQueueNode* mono_lock_free_queue_dequeue (MonoLockFreeQueue *q) MONO_INTERNAL;
  66
  67 #endif