Home
last modified time | relevance | path

Searched refs:create_task (Results 1 – 25 of 42) sorted by relevance

12

/external/python/cpython3/Lib/test/test_asyncio/
Dtest_locks.py119 t1 = self.loop.create_task(c1(result))
120 t2 = self.loop.create_task(c2(result))
132 t3 = self.loop.create_task(c3(result))
154 task = self.loop.create_task(lock.acquire())
188 ta = self.loop.create_task(lockit('A', fa))
191 tb = self.loop.create_task(lockit('B', None))
194 tc = self.loop.create_task(lockit('C', None))
233 t0 = self.loop.create_task(lockandtrigger())
234 t1 = self.loop.create_task(lockit())
235 t2 = self.loop.create_task(lockit())
[all …]
Dtest_queues.py47 loop.create_task(q.get())
61 loop.create_task(q.put(2))
146 t = loop.create_task(putter())
215 queue_get_task = loop.create_task(queue_get())
255 get_task = loop.create_task(queue_get())
267 t1 = self.loop.create_task(q.get())
268 t2 = self.loop.create_task(q.get())
281 self.loop.create_task(q.put('a'))
282 self.loop.create_task(q.put('b'))
325 self.loop.run_until_complete(self.loop.create_task(consumer(queue)))
[all …]
Dtest_sock_lowlevel.py132 task = asyncio.create_task(self.loop.sock_recv(sock, 1024))
136 asyncio.create_task(
150 task = asyncio.create_task(
155 task = asyncio.create_task(
171 task = asyncio.create_task(
189 task = asyncio.create_task(
202 task = asyncio.create_task(recv_all())
224 task = asyncio.create_task(self.loop.sock_connect(sock, addr))
285 task = asyncio.create_task(self.loop.sock_sendall(sock, chunk))
334 task = asyncio.create_task(self.loop.sock_sendall(sock, chunk))
Dtest_runners.py114 lo_task = asyncio.create_task(leftover())
135 lo_task = asyncio.create_task(leftover())
173 lazyboy = asyncio.create_task(spin())
Dtest_streams.py164 read_task = self.loop.create_task(stream.read(30))
188 read_task = self.loop.create_task(stream.read(1024))
201 read_task = self.loop.create_task(stream.read(-1))
244 read_task = self.loop.create_task(stream.readline())
500 read_task = self.loop.create_task(stream.readexactly(n))
523 read_task = self.loop.create_task(stream.readexactly(n))
563 t1 = self.loop.create_task(stream.readline())
564 t2 = self.loop.create_task(set_err())
573 t = self.loop.create_task(stream.readline())
606 self.loop.create_task(self.handle_client(client_reader,
[all …]
Dtest_server.py54 main_task = self.loop.create_task(main(srv))
109 main_task = self.loop.create_task(main(srv))
Dtest_base_events.py739 task = self.loop.create_task(coro())
746 task = self.loop.create_task(coro())
789 def create_task(self, coro): member in BaseEventLoopTests.test_create_task.EventLoop
808 task = loop.create_task(test(), name='test_task')
824 task = loop.create_task(test(), name='test_task')
956 asyncio.create_task(iter_one())
958 asyncio.create_task(iter_one())
1078 return self.loop.create_task(getaddrinfo(*args, **kwds))
1197 return self.loop.create_task(getaddrinfo(*args, **kwds))
1209 return self.loop.create_task(getaddrinfo(*args, **kwds))
[all …]
Dtest_subprocess.py410 task = self.loop.create_task(proc.wait())
430 task = self.loop.create_task(coro)
448 task = self.loop.create_task(coro)
Dtest_pep492.py206 t = self.loop.create_task(coro)
Dtest_tasks.py487 task = self.loop.create_task(partial_func(2))
1134 task = loop.create_task(asyncio.wait_for(fut, timeout=1))
1631 a = loop.create_task(asyncio.sleep(0.1, 'a'))
1632 b = loop.create_task(asyncio.sleep(0.15, 'b'))
2493 task = loop.create_task(blocking_coroutine())
2495 wait = loop.create_task(asyncio.wait_for(task, timeout))
2681 task = asyncio.create_task(inner())
2694 task = asyncio.create_task(coro_noop(), name='No-op')
2771 task = loop.create_task(sub(random.randint(0, 10)))
3012 task = self.loop.create_task(coro())
[all …]
/external/tensorflow/tensorflow/core/data/service/
Ddispatcher_state.cc55 CreateTask(update.create_task()); in Apply()
186 void DispatcherState::CreateTask(const CreateTaskUpdate& create_task) { in CreateTask() argument
187 int64 task_id = create_task.task_id(); in CreateTask()
190 auto& job = jobs_[create_task.job_id()]; in CreateTask()
192 task = std::make_shared<Task>(task_id, job, create_task.worker_address(), in CreateTask()
193 create_task.transfer_address()); in CreateTask()
194 tasks_by_job_[create_task.job_id()].push_back(task); in CreateTask()
195 tasks_by_worker_[create_task.worker_address()][task->task_id] = task; in CreateTask()
Ddispatcher_impl.cc591 CreatePendingTaskUpdate* create_task = update.mutable_create_pending_task(); in CreatePendingTask() local
592 create_task->set_task_id(task_id); in CreatePendingTask()
593 create_task->set_job_id(job->job_id); in CreatePendingTask()
594 create_task->set_worker_address(worker_address); in CreatePendingTask()
595 create_task->set_starting_round(round_robin_rounds_[job->job_id] + 1); in CreatePendingTask()
598 create_task->set_transfer_address(worker->transfer_address); in CreatePendingTask()
609 CreateTaskUpdate* create_task = update.mutable_create_task(); in CreateTask() local
610 create_task->set_task_id(task_id); in CreateTask()
611 create_task->set_job_id(job->job_id); in CreateTask()
612 create_task->set_worker_address(worker_address); in CreateTask()
[all …]
Ddispatcher_state_test.cc109 CreateTaskUpdate* create_task = update.mutable_create_task(); in CreateTask() local
110 create_task->set_task_id(task_id); in CreateTask()
111 create_task->set_job_id(job_id); in CreateTask()
112 create_task->set_worker_address(worker_address); in CreateTask()
Djournal.proto20 CreateTaskUpdate create_task = 3; field
Ddispatcher_state.h221 void CreateTask(const CreateTaskUpdate& create_task);
/external/python/cpython3/Lib/asyncio/
Dstaggered.py99 next_task = loop.create_task(run_one_coro(this_failed))
130 first_task = loop.create_task(run_one_coro(None))
D__main__.py50 repl_future = self.loop.create_task(coro)
Dtasks.py355 def create_task(coro, *, name=None): function
361 task = loop.create_task(coro)
664 task = loop.create_task(coro_or_future)
/external/python/cpython3/Doc/library/
Dasyncio-future.rst54 See also the :func:`create_task` function which is the
225 # We are using the low-level "loop.create_task()" API here because
227 # Otherwise we could have just used "asyncio.create_task()".
228 loop.create_task(
Dasyncio-task.rst76 * The :func:`asyncio.create_task` function to run coroutines
83 task1 = asyncio.create_task(
86 task2 = asyncio.create_task(
160 :func:`asyncio.create_task` the coroutine is automatically
171 task = asyncio.create_task(nested())
250 .. function:: create_task(coro, \*, name=None)
270 task = asyncio.create_task(coro())
581 task = asyncio.create_task(foo())
762 Use the high-level :func:`asyncio.create_task` function to create
763 Tasks, or the low-level :meth:`loop.create_task` or
[all …]
Dasyncio-dev.rst158 or the coroutine is not scheduled with :meth:`asyncio.create_task`, asyncio
190 :meth:`asyncio.create_task` function::
212 asyncio.create_task(bug())
Dasyncio-llapi-index.rst120 * - :meth:`loop.create_task`
124 - Set a factory used by :meth:`loop.create_task` to
128 - Get the factory :meth:`loop.create_task` uses
/external/python/cpython3/Lib/unittest/
Dasync_case.py118 self._asyncioCallsTask = loop.create_task(self._asyncioLoopRunner(fut))
/external/python/cpython3/Lib/test/
Dtest_asyncgen.py747 task = asyncio.create_task(target())
1060 t1 = self.loop.create_task(wait())
1061 t2 = self.loop.create_task(wait())
1200 asyncio.create_task(ag.aclose())
/external/python/cpython3/Misc/NEWS.d/
D3.7.0a4.rst344 Optimize asyncio.iscoroutine() and loop.create_task() for non-native
346 'loop.create_task(python_coroutine)' used to be 20% faster than
347 'loop.create_task(cython_coroutine)'. Now, the latter is as fast.
417 Implement asyncio.create_task(coro) shortcut

12