equal
deleted
inserted
replaced
151 |
151 |
152 WorkData worker_wait_for_task() { |
152 WorkData worker_wait_for_task() { |
153 // Wait for the coordinator to dispatch a task. |
153 // Wait for the coordinator to dispatch a task. |
154 _start_semaphore->wait(); |
154 _start_semaphore->wait(); |
155 |
155 |
156 uint num_started = Atomic::add(1u, &_started); |
156 uint num_started = Atomic::add(&_started, 1u); |
157 |
157 |
158 // Subtract one to get a zero-indexed worker id. |
158 // Subtract one to get a zero-indexed worker id. |
159 uint worker_id = num_started - 1; |
159 uint worker_id = num_started - 1; |
160 |
160 |
161 return WorkData(_task, worker_id); |
161 return WorkData(_task, worker_id); |