MCPcopy Create free account
hub / github.com/baidu/babylon / babylon_queue_consume

Function babylon_queue_consume

example/use-execution-queue/example.cpp:49–56  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

47}
48
49void babylon_queue_consume(
50 ::babylon::ConcurrentExecutionQueue<Task>::Iterator iter,
51 ::babylon::ConcurrentExecutionQueue<Task>::Iterator end) {
52 for (; iter != end; ++iter) {
53 latency << ::butil::monotonic_time_ns() - iter->begin;
54 pending << -1;
55 }
56}
57
58void run_loop() {
59 size_t times = 0;

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected