| 413 | butil::atomic<int> num_threads(0); |
| 414 | |
| 415 | void* push_thread_with_id(void* arg) { |
| 416 | bthread::ExecutionQueueId<LongIntTask> id = { (uint64_t)arg }; |
| 417 | int thread_id = num_threads.fetch_add(1, butil::memory_order_relaxed); |
| 418 | LOG(INFO) << "Start thread" << thread_id; |
| 419 | for (int i = 0; i < 100000; ++i) { |
| 420 | bthread::execution_queue_execute(id, ((long)thread_id << 32) | i); |
| 421 | } |
| 422 | return NULL; |
| 423 | } |
| 424 | |
| 425 | int check_order(void* meta, bthread::TaskIterator<LongIntTask>& iter) { |
| 426 | for (; iter; ++iter) { |
nothing calls this directly
no test coverage detected