diff --git a/toydispatch/toydispatch.c b/toydispatch/toydispatch.c index ae70a42..b80a942 100644 --- a/toydispatch/toydispatch.c +++ b/toydispatch/toydispatch.c @@ -183,7 +183,7 @@ static inline void read_from_queue(dispatch_queue_t queue, unsigned int idx = MASK(queue->consumer); *function = queue->ring_buffer[idx].function; *data = queue->ring_buffer[idx].data; - __sync_fetch_and_add(&queue->consumer, 2); + __sync_fetch_and_add(&queue->consumer, 1); } static void *runloop(void *q)