view src/sync_dequeue.c @ 11:12d1c2f53258

revision
author Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
date Sun, 14 Feb 2016 07:02:11 +0900
parents a8c53472e1a3
children
line wrap: on
line source

// Dequeue
__code getQueue(struct Context* context, struct Queue* queue, struct Node* node) {
    if (queue->first == 0)
        return;

    struct Element* first = queue->first;
    if (__sync_bool_compare_and_swap(&queue->first, first, first->next)) {
        queue->count--;

        context->next = GetQueue;
        stack_push(context->code_stack, &context->next);

        context->next = first->task->code;
        node->key = first->task->key;

        goto meta(context, Get);
    } else {
        goto meta(context, GetQueue);
    }
}