| 146 | } |
| 147 | |
| 148 | void thread(unsigned int tid) |
| 149 | { |
| 150 | RelacyThreadExitNotifier::notify_relacy_thread_start(); |
| 151 | |
| 152 | if (tid <= 1) { |
| 153 | int item; |
| 154 | ConsumerToken t(q); |
| 155 | for (int i = 0; i != 5; ++i) { |
| 156 | q.try_dequeue(t, item); |
| 157 | } |
| 158 | } |
| 159 | else { |
| 160 | ProducerToken t(q); |
| 161 | for (int i = 0; i != 3; ++i) { |
| 162 | q.enqueue(t, tid * 10 + i); |
| 163 | } |
| 164 | } |
| 165 | |
| 166 | RelacyThreadExitNotifier::notify_relacy_thread_exit(); |
| 167 | } |
| 168 | |
| 169 | void after() |
| 170 | { |
nothing calls this directly
no test coverage detected