| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ChannelExecutorTest.java | 55 private Runnable task1; field in ChannelExecutorTest
73 executor.executeLater(task1); in singleThread()
75 InOrder inOrder = inOrder(task1, task2, task3); in singleThread()
78 inOrder.verify(task1).run(); in singleThread()
89 InOrder inOrder = inOrder(task1, task2); in multiThread()
110 }).when(task1).run(); in multiThread()
123 executor.executeLater(task1); in multiThread()
137 inOrder.verify(task1).run(); in multiThread()
151 InOrder inOrder = inOrder(task1, task2, task3); in taskThrows()
159 executor.executeLater(task1); in taskThrows()
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | batch_scheduler_test.cc | 57 auto task1 = new FakeTask(7); in TEST() local
58 batch.AddTask(std::unique_ptr<FakeTask>(task1)); in TEST()
62 EXPECT_EQ(task0->size() + task1->size(), batch.size()); in TEST()
63 EXPECT_EQ(task1->size(), batch.task(1).size()); in TEST()
64 EXPECT_EQ(task1->size(), batch.mutable_task(1)->size()); in TEST()
72 EXPECT_EQ(task0->size() + task1->size(), batch.size()); in TEST()
74 EXPECT_EQ(task1->size(), batch.task(1).size()); in TEST()
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowHandlerTest.java | 146 TestRunnable task1 = new TestRunnable(); in testPostDelayedTwiceThenRunMainLooperToNextTask_shouldRunMultipleTasks() local
149 new Handler().postDelayed(task1, 1); in testPostDelayedTwiceThenRunMainLooperToNextTask_shouldRunMultipleTasks()
153 assertThat(task1.wasRun).isTrue(); in testPostDelayedTwiceThenRunMainLooperToNextTask_shouldRunMultipleTasks()
159 TestRunnable task1 = new TestRunnable(); in testPostDelayedTwiceThenRunMainLooperOneTask_shouldRunOnlyOneTask() local
162 new Handler().postDelayed(task1, 1); in testPostDelayedTwiceThenRunMainLooperOneTask_shouldRunOnlyOneTask()
166 assertThat(task1.wasRun).isTrue(); in testPostDelayedTwiceThenRunMainLooperOneTask_shouldRunOnlyOneTask()
172 TestRunnable task1 = new TestRunnable(); in testPostDelayedMultipleThenRunMainLooperOneTask_shouldRunMultipleTask() local
176 new Handler().postDelayed(task1, 1); in testPostDelayedMultipleThenRunMainLooperOneTask_shouldRunMultipleTask()
181 assertThat(task1.wasRun).isTrue(); in testPostDelayedMultipleThenRunMainLooperOneTask_shouldRunMultipleTask()
188 TestRunnable task1 = new TestRunnable(); in testPostAtFrontOfQueueThenRunMainLooperOneTaskAtATime_shouldRunFrontOfQueueTaskFirst() local
[all …]
|
| D | ShadowActivityManagerTest.java | 57 …final ActivityManager.RunningTaskInfo task1 = 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()
69 final AppTask task1 = 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 | 174 OnceClosure task1 = in TEST_F() local
181 ExpectedTrace({}), std::move(task1)); in TEST_F()
349 OnceClosure task1 = BindOnce( in TEST_F() local
361 ExpectedTrace({}), std::move(task1)); in TEST_F()
|
| D | activity_tracker_unittest.cc | 218 PendingTask task1(FROM_HERE, DoNothing()); in TEST_F() local
219 ScopedTaskRunActivity activity1(task1); in TEST_F()
|
| /external/libchrome/base/test/ |
| D | test_mock_time_task_runner_unittest.cc | 238 CancelableClosure task1(Bind([]() {})); in TEST() local
239 task_runner->PostDelayedTask(FROM_HERE, task1.callback(), in TEST()
244 task1.Cancel(); in TEST()
|
| /external/libchrome/base/task/sequence_manager/ |
| D | sequence_manager_impl_unittest.cc | 1997 CancelableTask task1(GetTickClock()); in TEST_P() local
2003 task1.weak_factory_.GetWeakPtr(), &run_times), in TEST_P()
2011 task1.weak_factory_.InvalidateWeakPtrs(); in TEST_P()
2332 CancelableTask task1(GetTickClock()); in TEST_P() local
2344 task1.weak_factory_.GetWeakPtr(), &run_times), in TEST_P()
2383 CancelableTask task1(GetTickClock()); in TEST_P() local
2410 task1.weak_factory_.GetWeakPtr(), &run_times), in TEST_P()
2434 CancelableTask task1(GetTickClock()); in TEST_P() local
2446 task1.weak_factory_.GetWeakPtr(), &run_times), in TEST_P()
2473 task1.weak_factory_.InvalidateWeakPtrs(); in TEST_P()
[all …]
|
| D | task_queue_selector_unittest.cc | 804 TaskQueueImpl::Task task1(TaskQueue::PostedTask(test_closure_, FROM_HERE), in TEST_F() local
810 task_queue->immediate_work_queue()->Push(std::move(task1)); in TEST_F()
|
| /external/autotest/scheduler/ |
| D | host_scheduler_unittests.py | 151 task1 = self.db_helper.create_special_task(job1.id)
165 self.assertTrue(tasks[0].id == task1.id)
186 task1 = self.db_helper.create_special_task(host_id=host1.id)
|
| /external/autotest/server/lib/ |
| D | status_history.py | 669 task1 = query1.order_by('time_started')[0]
671 task1.time_finished.strftime(time_utils.TIME_FMT)]
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 1655 self.assertTrue(asyncio.current_task(loop=loop) is task1)
1657 self.assertTrue(asyncio.current_task(loop=loop) is task1)
1666 task1 = self.new_task(self.loop, coro1(self.loop))
1669 self.loop.run_until_complete(asyncio.wait((task1, task2),
2674 task1 = mock.Mock()
2677 self._enter_task(loop, task1)
2680 self.assertIs(asyncio.current_task(loop), task1)
2681 self._leave_task(loop, task1)
2691 task1 = mock.Mock()
2694 self._enter_task(loop, task1)
[all …]
|
| /external/tensorflow/tensorflow/core/grappler/optimizers/ |
| D | memory_optimizer.cc | 1234 string task1; in CrossesTaskOrCpuGpuBoundary() local
1236 DeviceNameUtils::SplitDeviceName(node1.device(), &task1, &device1); in CrossesTaskOrCpuGpuBoundary()
1240 return task1 != task2 || in CrossesTaskOrCpuGpuBoundary()
|
| /external/python/cpython2/Doc/tutorial/ |
| D | stdlib2.rst | 312 >>> d = deque(["task1", "task2", "task3"])
315 Handling task1
|
| /external/python/cpython3/Doc/tutorial/ |
| D | stdlib2.rst | 314 >>> d = deque(["task1", "task2", "task3"])
317 Handling task1
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-task.rst | 83 task1 = asyncio.create_task(
93 await task1
|
| /external/autotest/frontend/afe/ |
| D | rpc_interface_unittest.py | 929 self.task1 = models.SpecialTask.objects.create(
|