| 110 | } |
| 111 | |
| 112 | void* dequeue_thread(void* ctx) |
| 113 | { |
| 114 | queue_t* q = static_cast<queue_t*>(ctx); |
| 115 | for (size_t i = 0; i != 4; i += 1) |
| 116 | { |
| 117 | void* data = q->dequeue(); |
| 118 | assert((int)(uintptr_t)data >= 1 && (int)(uintptr_t)data <= 4); |
| 119 | } |
| 120 | return 0; |
| 121 | } |
| 122 | |
| 123 | void queue_test() |
| 124 | { |