| 99 | } |
| 100 | |
| 101 | void block() { |
| 102 | // Coro_switchTo_( swapCoro(main_coro), main_coro ); |
| 103 | blocked = Promise<Void>(); |
| 104 | double before = now(); |
| 105 | CoroThreadPool::waitFor(blocked.getFuture()); |
| 106 | if (g_network->isSimulated() && g_simulator.getCurrentProcess()->rebooting) |
| 107 | TraceEvent("CoroUnblocked").detail("After", now() - before); |
| 108 | } |
| 109 | |
| 110 | virtual void run() = 0; |
| 111 |