| 300 | } |
| 301 | |
| 302 | int JobQueue::enqueue(JobItem* jobItem) SKR_NOEXCEPT |
| 303 | { |
| 304 | // Add to pending queue |
| 305 | skr_rw_mutex_acquire_w(&pending_queue_mutex); |
| 306 | SKR_DEFER({skr_rw_mutex_release_w(&pending_queue_mutex);}); |
| 307 | JobResult ret; |
| 308 | { |
| 309 | ret = enqueueCore(jobItem, /*isEndJob=*/false); |
| 310 | } |
| 311 | if (ret == ASYNC_RESULT_OK) |
| 312 | { |
| 313 | pending_queue.emplace_back(jobItem); |
| 314 | } |
| 315 | return ret; |
| 316 | } |
| 317 | |
| 318 | bool JobQueue::is_empty() SKR_NOEXCEPT |
| 319 | { |
no test coverage detected