/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
D | ChannelExecutorTest.java | 58 private Runnable task2; field in ChannelExecutorTest 74 executor.executeLater(task2); in singleThread() 75 InOrder inOrder = inOrder(task1, task2, task3); in singleThread() 79 inOrder.verify(task2).run(); in singleThread() 89 InOrder inOrder = inOrder(task1, task2); in multiThread() 118 }).when(task2).run(); in multiThread() 132 executor.executeLater(task2); in multiThread() 143 inOrder.verify(task2).run(); in multiThread() 151 InOrder inOrder = inOrder(task1, task2, task3); in taskThrows() 158 }).when(task2).run(); in taskThrows() [all …]
|
/external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
D | ShadowHandlerTest.java | 147 TestRunnable task2 = new TestRunnable(); in testPostDelayedTwiceThenRunMainLooperToNextTask_shouldRunMultipleTasks() local 150 new Handler().postDelayed(task2, 1); in testPostDelayedTwiceThenRunMainLooperToNextTask_shouldRunMultipleTasks() 154 assertThat(task2.wasRun).isTrue(); in testPostDelayedTwiceThenRunMainLooperToNextTask_shouldRunMultipleTasks() 160 TestRunnable task2 = new TestRunnable(); in testPostDelayedTwiceThenRunMainLooperOneTask_shouldRunOnlyOneTask() local 163 new Handler().postDelayed(task2, 1); in testPostDelayedTwiceThenRunMainLooperOneTask_shouldRunOnlyOneTask() 167 assertThat(task2.wasRun).isFalse(); in testPostDelayedTwiceThenRunMainLooperOneTask_shouldRunOnlyOneTask() 173 TestRunnable task2 = new TestRunnable(); in testPostDelayedMultipleThenRunMainLooperOneTask_shouldRunMultipleTask() local 177 new Handler().postDelayed(task2, 10); in testPostDelayedMultipleThenRunMainLooperOneTask_shouldRunMultipleTask() 182 assertThat(task2.wasRun).isTrue(); in testPostDelayedMultipleThenRunMainLooperOneTask_shouldRunMultipleTask() 189 TestRunnable task2 = new TestRunnable(); in testPostAtFrontOfQueueThenRunMainLooperOneTaskAtATime_shouldRunFrontOfQueueTaskFirst() local [all …]
|
D | ShadowActivityManagerTest.java | 58 …final ActivityManager.RunningTaskInfo task2 = buildTaskInfo(new ComponentName("org.robolectric", "… in getRunningTasks_shouldReturnTaskList() local 61 shadowOf(activityManager).setTasks(Lists.newArrayList(task1, task2)); in getRunningTasks_shouldReturnTaskList() 62 assertThat(activityManager.getRunningTasks(Integer.MAX_VALUE)).containsExactly(task1, task2); in getRunningTasks_shouldReturnTaskList() 70 final AppTask task2 = ShadowAppTask.newInstance(); in getAppTasks_shouldReturnAppTaskList() local 73 shadowOf(activityManager).setAppTasks(Lists.newArrayList(task1, task2)); in getAppTasks_shouldReturnAppTaskList() 74 assertThat(activityManager.getAppTasks()).containsExactly(task1, task2); in getAppTasks_shouldReturnAppTaskList()
|
/external/libchrome/base/debug/ |
D | task_annotator_unittest.cc | 169 OnceClosure task2 = BindOnce( in TEST_F() local 177 ExpectedTrace({location0.program_counter()}), std::move(task2)); in TEST_F() 339 OnceClosure task2 = BindOnce( in TEST_F() local 351 OnceClosure task2) { in TEST_F() argument 354 ThreadTaskRunnerHandle::Get()->PostTask(location2, std::move(task2)); in TEST_F() 356 Unretained(&nested_run_loop2), location2, std::move(task2)); in TEST_F()
|
D | activity_tracker_unittest.cc | 229 PendingTask task2(FROM_HERE, DoNothing()); in TEST_F() local 230 ScopedTaskRunActivity activity2(task2); in TEST_F()
|
/external/libcxx/test/std/utilities/function.objects/bind/func.bind/func.bind.bind/ |
D | copy.pass.cpp | 34 auto task2(task); in main() local 36 assert(task2() == 16); in main()
|
/external/libchrome/base/test/ |
D | test_mock_time_task_runner_unittest.cc | 247 CancelableClosure task2(Bind([]() {})); in TEST() local 248 task_runner->PostDelayedTask(FROM_HERE, task2.callback(), in TEST() 250 task2.Cancel(); in TEST()
|
/external/python/cpython3/Lib/test/ |
D | test_thread.py | 191 thread.start_new_thread(self.task2, (i,)) 196 def task2(self, ident): member in BarrierTest
|
/external/python/cpython2/Lib/test/ |
D | test_thread.py | 193 thread.start_new_thread(self.task2, (i,)) 198 def task2(self, ident): member in BarrierTest
|
/external/libchrome/base/task/sequence_manager/ |
D | sequence_manager_impl_unittest.cc | 1998 CancelableTask task2(GetTickClock()); in TEST_P() local 2008 task2.weak_factory_.GetWeakPtr(), &run_times), in TEST_P() 2333 CancelableTask task2(GetTickClock()); in TEST_P() local 2349 task2.weak_factory_.GetWeakPtr(), &run_times), in TEST_P() 2362 task2.weak_factory_.InvalidateWeakPtrs(); in TEST_P() 2384 CancelableTask task2(GetTickClock()); in TEST_P() local 2405 task2.weak_factory_.GetWeakPtr(), &run_times), in TEST_P() 2413 task2.weak_factory_.InvalidateWeakPtrs(); in TEST_P() 2435 CancelableTask task2(GetTickClock()); in TEST_P() local 2451 task2.weak_factory_.GetWeakPtr(), &run_times), in TEST_P() [all …]
|
D | task_queue_selector_unittest.cc | 807 TaskQueueImpl::Task task2(TaskQueue::PostedTask(test_closure_, FROM_HERE), in TEST_F() local 811 task_queue2->immediate_work_queue()->Push(std::move(task2)); in TEST_F()
|
/external/python/cpython3/Lib/test/test_asyncio/ |
D | test_tasks.py | 1661 self.assertTrue(asyncio.current_task(loop=loop) is task2) 1664 self.assertTrue(asyncio.current_task(loop=loop) is task2) 1667 task2 = self.new_task(self.loop, coro2(self.loop)) 1669 self.loop.run_until_complete(asyncio.wait((task1, task2), 2675 task2 = mock.Mock() 2679 self._enter_task(loop, task2) 2692 task2 = mock.Mock() 2696 self._leave_task(loop, task2)
|
/external/tensorflow/tensorflow/core/grappler/optimizers/ |
D | memory_optimizer.cc | 1237 string task2; in CrossesTaskOrCpuGpuBoundary() local 1239 DeviceNameUtils::SplitDeviceName(node2.device(), &task2, &device2); in CrossesTaskOrCpuGpuBoundary() 1240 return task1 != task2 || in CrossesTaskOrCpuGpuBoundary()
|
/external/autotest/scheduler/ |
D | host_scheduler_unittests.py | 155 task2 = self.db_helper.create_special_task(host_id=host.id)
|
/external/autotest/frontend/afe/ |
D | rpc_interface_unittest.py | 933 self.task2 = models.SpecialTask.objects.create( 955 self.task2.time_started = datetime.datetime(2009, 1, 2) 956 self.task2.save()
|
/external/python/cpython3/Doc/library/ |
D | asyncio-task.rst | 86 task2 = asyncio.create_task( 94 await task2
|
/external/python/cpython2/Doc/tutorial/ |
D | stdlib2.rst | 312 >>> d = deque(["task1", "task2", "task3"])
|
/external/python/cpython3/Doc/tutorial/ |
D | stdlib2.rst | 314 >>> d = deque(["task1", "task2", "task3"])
|