| 115 | } |
| 116 | |
| 117 | void kernel::notify_fail(size_t task_id){ |
| 118 | std::lock_guard<std::mutex> lock(kernel_mutex); |
| 119 | this->tasks.erase(task_id); |
| 120 | kernel_cv.notify_one(); |
| 121 | } |
| 122 | |
| 123 | // This is only the default estimate of the bytes to be output by a kernel based on the input. |
| 124 | // Each kernel should implement its own version of this, if its possible to obtain a better estimate |