| 171 | } |
| 172 | |
| 173 | void Async::cancel() { |
| 174 | for (auto event = _workerEvent.poll(); |
| 175 | event != nullptr; |
| 176 | event = _workerEvent.poll()) { |
| 177 | switch (Switch::hash(event->getName())) { |
| 178 | case "Work"_hash: { |
| 179 | Own<std::function<void()>> worker; |
| 180 | break; |
| 181 | } |
| 182 | case "WorkDone"_hash: { |
| 183 | Own<WorkDone> workDone; |
| 184 | event->get(workDone); |
| 185 | break; |
| 186 | } |
| 187 | } |
| 188 | } |
| 189 | } |
| 190 | |
| 191 | void Async::bindPool(AsyncThread* pool, size_t index) { |
| 192 | _pool = pool; |