| /third_party/boost/libs/spirit/classic/test/ |
| D | grammar_mt_tests.cpp | 182 single_grammar_object_task task1, task2, task3, task4; in single_local_grammar_object_multiple_threads() local
184 boost::thread t1(callable_ref(task1)); in single_local_grammar_object_multiple_threads()
216 two_grammar_objects_task task1, task2, task3, task4; in multiple_local_grammar_objects_multiple_threads() local
218 boost::thread t1(callable_ref(task1)); in multiple_local_grammar_objects_multiple_threads()
248 single_global_grammar_object_task task1, task2, task3, task4; in single_global_grammar_object_multiple_threads() local
250 boost::thread t1(callable_ref(task1)); in single_global_grammar_object_multiple_threads()
282 multiple_global_grammar_objects_task task1, task2, task3, task4; in multiple_global_grammar_objects_multiple_threads() local
284 boost::thread t1(callable_ref(task1)); in multiple_global_grammar_objects_multiple_threads()
|
| /third_party/mindspore/tests/ut/cpp/device/ |
| D | ge_runtime_test.cc | 225 …std::shared_ptr<Task> task1 = TaskFactory::GetInstance().Create(model_context, label_goto_task_inf… in TEST_F() local
227 auto label_goto_task_1 = std::dynamic_pointer_cast<LabelGotoTask>(task1); in TEST_F()
230 ASSERT_NO_THROW(task1->Distribute()); in TEST_F()
289 …std::shared_ptr<Task> task1 = TaskFactory::GetInstance().Create(model_context, label_switch_task_i… in TEST_F() local
291 auto label_switch_task_1 = std::dynamic_pointer_cast<LabelSwitchTask>(task1); in TEST_F()
295 ASSERT_NO_THROW(task1->Distribute()); in TEST_F()
|
| /third_party/mindspore/mindspore/ccsrc/backend/kernel_compiler/cpu/ |
| D | layer_norm_grad_cpu_kernel.cc | 92 auto task1 = [this, &x, &dy, &var, &mean, &dg, &db, thread_num1](size_t start) { in LaunchKernel() local
140 task1(i); in LaunchKernel()
|
| D | roi_align_grad_cpu_kernel.cc | 117 auto task1 = [this, &dx](size_t start, size_t end) { in Launch() local
123 CPUKernelUtils::ParallelFor(task1, IntToSize(size_init)); in Launch()
|
| D | nms_with_mask_cpu_kernel.cc | 46 auto task1 = [this, &data_buff, &index_buff, &input, inner, box_size](int start, int end) { in NmsBitonicSortByKeyKernel() local
52 CPUKernelUtils::ParallelFor(task1, ceil_power2); in NmsBitonicSortByKeyKernel()
|
| /third_party/libwebsockets/lib/misc/threadpool/ |
| D | threadpool.c | 1129 struct lws_threadpool_task *task1; in lws_threadpool_foreach_task_wsi() local
1134 task1 = lws_container_of(wsi->tp_task_owner.head, in lws_threadpool_foreach_task_wsi()
1137 pthread_mutex_lock(&task1->tp->lock); /* ================ tpool lock */ in lws_threadpool_foreach_task_wsi()
1145 pthread_mutex_unlock(&task1->tp->lock); /* ------------ tpool unlock */ in lws_threadpool_foreach_task_wsi()
1151 pthread_mutex_unlock(&task1->tp->lock); /* ------------ tpool unlock */ in lws_threadpool_foreach_task_wsi()
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/health_check/ |
| D | health_servicer_test.py | 172 task1 = self.loop.create_task(_pipe_to_queue(call1, queue1))
191 await task1
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/unit/ |
| D | call_test.py | 133 task1 = self.loop.create_task(coro())
138 self.assertEqual(expected, await asyncio.gather(*[task1, task2]))
162 task1 = self.loop.create_task(coro())
168 asyncio.gather(task1, task2))
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/perf/ |
| D | cpu_sampling.cc | 282 for (auto &task1 : allTasks) { in Collect() local
283 int32_t op_id = task1.get_operator_id(); in Collect()
284 op_thread_[op_id].emplace_back(task1.get_linux_id()); in Collect()
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_tasks.py | 2057 self.assertTrue(asyncio.current_task() is task1)
2059 self.assertTrue(asyncio.current_task() is task1)
2068 task1 = self.new_task(self.loop, coro1(self.loop))
2071 self.loop.run_until_complete(asyncio.wait((task1, task2)))
3142 task1 = mock.Mock()
3145 self._enter_task(loop, task1)
3148 self.assertIs(asyncio.current_task(loop), task1)
3149 self._leave_task(loop, task1)
3159 task1 = mock.Mock()
3162 self._enter_task(loop, task1)
[all …]
|
| /third_party/python/Doc/tutorial/ |
| D | stdlib2.rst | 314 >>> d = deque(["task1", "task2", "task3"])
317 Handling task1
|
| /third_party/mindspore/tests/ut/cpp/dataset/ |
| D | deserialize_test.cc | 424 std::string task1 = "AFQMC"; in TEST_F() local
428 std::make_shared<CLUENode>(files, task1, usage, 0, ShuffleMode::kFalse, 1, 0, cache); in TEST_F()
|
| /third_party/python/Doc/library/ |
| D | asyncio-task.rst | 83 task1 = asyncio.create_task(
93 await task1
|