Home
last modified time | relevance | path

Searched refs:running_tasks (Results 1 – 3 of 3) sorted by relevance

/third_party/python/Lib/asyncio/
Dstaggered.py80 running_tasks = []
100 running_tasks.append(next_task)
101 assert len(running_tasks) == this_index + 2
126 for i, t in enumerate(running_tasks):
131 running_tasks.append(first_task)
136 while done_count != len(running_tasks):
137 done, _ = await tasks.wait(running_tasks)
148 for t in running_tasks:
/third_party/libwebsockets/lib/misc/threadpool/
Dthreadpool.c97 int running_tasks; member
183 tp->name, tp->queue_depth, tp->running_tasks, in lws_threadpool_dump()
213 if (count != tp->running_tasks) in lws_threadpool_dump()
215 __func__, tp->running_tasks, count); in lws_threadpool_dump()
553 tp->running_tasks++; in lws_threadpool_worker()
626 tp->running_tasks--; in lws_threadpool_worker()
/third_party/grpc/src/python/grpcio_tests/tests_aio/benchmark/
Dworker_servicer.py267 running_tasks = []
277 running_tasks.append(self._loop.create_task(client.run()))
292 for task in running_tasks: