Searched refs:WorkUnit (Results 1 – 3 of 3) sorted by relevance
29 private class WorkUnit { class in AsyncConcurrencyTest117 final ArrayBlockingQueue<WorkUnit> q = new ArrayBlockingQueue<WorkUnit>(20); in _testConcurrentAsyncOnce()119 q.add(new WorkUnit()); in _testConcurrentAsyncOnce()130 WorkUnit w = q.take(); in _testConcurrentAsyncOnce()
196 struct WorkUnit { struct205 struct WorkUnitWithResults : public WorkUnit {275 std::queue<WorkUnit> encode_queue_ ABSL_GUARDED_BY(mutex_);
139 WorkUnit work_unit; in EncodeAndSend()226 static_cast<WorkUnit&>(work_unit) = std::move(encode_queue_.front()); in ProcessWorkUnitsUntilTimeToQuit()