Home
last modified time | relevance | path

Searched defs:task (Results 1 – 25 of 806) sorted by relevance

12345678910>>...33

/external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/common/src/test/java/com/google/android/exoplayer2/util/
DRunnableFutureTaskTest.java34 RunnableFutureTask<Void, Exception> task = in blockUntilStarted_ifNotStarted_blocks() local
64 RunnableFutureTask<Void, Exception> task = in blockUntilStarted_ifStarted_unblocks() local
83 RunnableFutureTask<Void, Exception> task = in blockUntilStarted_ifCanceled_unblocks() local
100 RunnableFutureTask<Void, Exception> task = in blockUntilFinished_ifNotFinished_blocks() local
133 RunnableFutureTask<Void, Exception> task = in blockUntilFinished_ifFinished_unblocks() local
152 RunnableFutureTask<Void, Exception> task = in blockUntilFinished_ifCanceled_unblocks() local
169 RunnableFutureTask<Void, Exception> task = in get_ifNotFinished_blocks() local
208 RunnableFutureTask<Object, Exception> task = in get_returnsResult() local
227 RunnableFutureTask<Object, IOException> task = in get_throwsExecutionException_containsIOException() local
247 RunnableFutureTask<Object, Exception> task = in get_throwsExecutionException_containsRuntimeException() local
[all …]
/external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/common/src/test/java/com/google/android/exoplayer2/util/
DRunnableFutureTaskTest.java34 RunnableFutureTask<Void, Exception> task = in blockUntilStarted_ifNotStarted_blocks() local
64 RunnableFutureTask<Void, Exception> task = in blockUntilStarted_ifStarted_unblocks() local
83 RunnableFutureTask<Void, Exception> task = in blockUntilStarted_ifCanceled_unblocks() local
100 RunnableFutureTask<Void, Exception> task = in blockUntilFinished_ifNotFinished_blocks() local
133 RunnableFutureTask<Void, Exception> task = in blockUntilFinished_ifFinished_unblocks() local
152 RunnableFutureTask<Void, Exception> task = in blockUntilFinished_ifCanceled_unblocks() local
169 RunnableFutureTask<Void, Exception> task = in get_ifNotFinished_blocks() local
208 RunnableFutureTask<Object, Exception> task = in get_returnsResult() local
227 RunnableFutureTask<Object, IOException> task = in get_throwsExecutionException_containsIOException() local
247 RunnableFutureTask<Object, Exception> task = in get_throwsExecutionException_containsRuntimeException() local
[all …]
/external/pigweed/pw_async_basic/
Ddispatcher.cc87 backend::NativeTask& task = task_queue_.front(); in ExecuteDueTasks() local
112 backend::NativeTask& task = task_queue_.front(); in DrainTaskQueue() local
123 void BasicDispatcher::Post(Task& task) { PostAt(task, now()); } in Post()
125 void BasicDispatcher::PostAfter(Task& task, in PostAfter()
130 void BasicDispatcher::PostAt(Task& task, chrono::SystemClock::time_point time) { in PostAt()
137 void BasicDispatcher::PostPeriodic(Task& task, in PostPeriodic()
143 Task& task, in PostPeriodicAt()
151 bool BasicDispatcher::Cancel(Task& task) { in Cancel()
157 backend::NativeTask& task, chrono::SystemClock::time_point time_due) { in PostTaskInternal()
Dfake_dispatcher.cc91 void NativeFakeDispatcher::Post(Task& task) { PostAt(task, now()); } in Post()
93 void NativeFakeDispatcher::PostAfter(Task& task, in PostAfter()
98 void NativeFakeDispatcher::PostAt(Task& task, in PostAt()
105 Task& task, chrono::SystemClock::duration interval) { in PostPeriodic()
110 Task& task, in PostPeriodicAt()
117 bool NativeFakeDispatcher::Cancel(Task& task) { in Cancel()
122 ::pw::async::backend::NativeTask& task, in PostTaskInternal()
/external/skia/src/gpu/ganesh/
DGrDDLTask.cpp24 for (auto& task : fDDL->priv().renderTasks()) { in GrDDLTask() local
39 for (auto& task : fDDL->priv().renderTasks()) { in endFlush() local
47 for (auto& task : fDDL->priv().renderTasks()) { in disown() local
59 for (auto& task : fDDL->priv().renderTasks()) { in onIsUsed() local
73 for (auto& task : fDDL->priv().renderTasks()) { in gatherProxyIntervals() local
85 for (auto& task : fDDL->priv().renderTasks()) { in onPrepare() local
92 for (auto& task : fDDL->priv().renderTasks()) { in onExecute() local
121 for (auto& task : fDDL->priv().renderTasks()) { in dump() local
DGrDrawingManager.cpp110 bool used = std::any_of(fDAG.begin(), fDAG.end(), [&](auto& task) { in flush()
185 for (const auto& task : fDAG) { in flush() local
294 for (const auto& task : fDAG) { in removeRenderTasks() local
323 auto check = [&](const GrRenderTask* task, auto&& check) -> void { in sortTasks()
417 sk_sp<GrRenderTask>& task = fDAG[i]; in reorderTasks() local
434 for (auto& task : fDAG) { in closeAllTasks() local
441 GrRenderTask* GrDrawingManager::insertTaskBeforeLast(sk_sp<GrRenderTask> task) { in insertTaskBeforeLast()
457 GrRenderTask* GrDrawingManager::appendTask(sk_sp<GrRenderTask> task) { in appendTask()
549 void GrDrawingManager::setLastRenderTask(const GrSurfaceProxy* proxy, GrRenderTask* task) { in setLastRenderTask()
569 GrRenderTask* task = this->getLastRenderTask(proxy); in getLastOpsTask() local
[all …]
/external/webrtc/modules/utility/
Dmaybe_worker_thread.cc49 void MaybeWorkerThread::RunSynchronous(absl::AnyInvocable<void() &&> task) { in RunSynchronous()
53 std::move(task)(); in RunSynchronous() local
60 std::move(task)(); in RunSynchronous() local
64 void MaybeWorkerThread::RunOrPost(absl::AnyInvocable<void() &&> task) { in RunOrPost()
69 std::move(task)(); in RunOrPost() local
89 absl::AnyInvocable<void() &&> MaybeWorkerThread::MaybeSafeTask( in MaybeSafeTask()
/external/pigweed/pw_async/public/pw_async/
Dfake_dispatcher.h53 void Post(Task& task) override { native_dispatcher_.Post(task); } in Post()
54 void PostAfter(Task& task, chrono::SystemClock::duration delay) override { in PostAfter()
57 void PostAt(Task& task, chrono::SystemClock::time_point time) override { in PostAt()
60 void PostPeriodic(Task& task, in PostPeriodic()
64 void PostPeriodicAt(Task& task, in PostPeriodicAt()
69 bool Cancel(Task& task) override { return native_dispatcher_.Cancel(task); } in Cancel()
/external/libwebsockets/lib/misc/threadpool/
Dthreadpool.c75 struct lws_threadpool_task *task; member
125 __lws_threadpool_task_dump(struct lws_threadpool_task *task, char *buf, int len) in __lws_threadpool_task_dump()
237 state_transition(struct lws_threadpool_task *task, in state_transition()
245 task_to_wsi(struct lws_threadpool_task *task) in task_to_wsi()
255 lws_threadpool_task_cleanup_destroy(struct lws_threadpool_task *task) in lws_threadpool_task_cleanup_destroy()
269 __lws_threadpool_reap(struct lws_threadpool_task *task) in __lws_threadpool_reap()
319 struct lws_threadpool_task **c, *task = NULL; in lws_threadpool_tsi_context() local
393 struct lws_threadpool_task *task) in lws_threadpool_worker_sync()
493 struct lws_threadpool_task **c, **c2, *task; in lws_threadpool_worker() local
744 struct lws_threadpool_task **c, *task; in lws_threadpool_finish() local
[all …]
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DTrustedListenableFutureTaskTest.java42 TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2)); in testSuccessful() local
51 TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2)); in testCancelled() local
67 TrustedListenableFutureTask<Integer> task = in testFailed() local
91 final TrustedListenableFutureTask<Integer> task = in testCancel_interrupted() local
142 final TrustedListenableFutureTask<Integer> task = in testRunIdempotency() local
175 final TrustedListenableFutureTask<Void> task = in testToString() local
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DTrustedListenableFutureTaskTest.java42 TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2)); in testSuccessful() local
51 TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2)); in testCancelled() local
67 TrustedListenableFutureTask<Integer> task = in testFailed() local
91 final TrustedListenableFutureTask<Integer> task = in testCancel_interrupted() local
142 final TrustedListenableFutureTask<Integer> task = in testRunIdempotency() local
175 final TrustedListenableFutureTask<Void> task = in testToString() local
/external/rust/crates/tokio-util/tests/
Dframed_read.rs71 let mut task = task::spawn(()); in read_multi_frame_in_packet() localVariable
87 let mut task = task::spawn(()); in read_multi_frame_across_packets() localVariable
105 let mut task = task::spawn(()); in read_multi_frame_in_packet_after_codec_changed() localVariable
123 let mut task = task::spawn(()); in read_not_ready() localVariable
141 let mut task = task::spawn(()); in read_partial_then_not_ready() localVariable
160 let mut task = task::spawn(()); in read_err() localVariable
179 let mut task = task::spawn(()); in read_partial_then_err() localVariable
199 let mut task = task::spawn(()); in read_partial_would_block_then_err() localVariable
221 let mut task = task::spawn(()); in huge_size() localVariable
248 let mut task = task::spawn(()); in data_remaining_is_error() localVariable
[all …]
/external/ims/rcs/rcsservice/src/com/android/service/ims/
DTaskManager.java99 public void putTask(int taskId, Task task){ in putTask()
105 private synchronized void putTaskInternal(int taskId, Task task){ in putTaskInternal()
115 Task task = new PresenceCapabilityTask(context, taskId, TASK_TYPE_GET_CAPABILITY, in addCapabilityTask() local
128 Task task = new PresenceAvailabilityTask(taskId, TASK_TYPE_GET_AVAILABILITY, in addAvailabilityTask() local
141 Task task = new PresenceTask(taskId, TASK_TYPE_PUBLISH, null /*listener*/, contacts); in addPublishTask() local
157 Task task = mTaskMap.remove(String.valueOf(taskId)); in removeTask() local
174 Task task = mTaskMap.get(key); in getTaskForSingleContactQuery() local
225 Task task = mTaskMap.get(key); in onTerminated() local
256 Task task = getTaskByRequestId(requestId); in onTerminated() local
278 Task task = getTask(taskId); in onTimeout() local
[all …]
/external/libchrome/base/task_scheduler/
Dpost_task.cc25 bool PostTask(const Location& from_here, OnceClosure task) override { in PostTask()
45 void PostTask(const Location& from_here, OnceClosure task) { in PostTask()
50 OnceClosure task, in PostDelayedTask()
56 OnceClosure task, in PostTaskAndReply()
64 OnceClosure task) { in PostTaskWithTraits()
70 OnceClosure task, in PostDelayedTaskWithTraits()
83 OnceClosure task, in PostTaskWithTraitsAndReply()
Dpost_task.h101 OnceCallback<TaskReturnType()> task, in PostTaskAndReplyWithResult()
114 Callback<TaskReturnType()> task, in PostTaskAndReplyWithResult()
153 OnceCallback<TaskReturnType()> task, in PostTaskWithTraitsAndReplyWithResult()
172 Callback<TaskReturnType()> task, in PostTaskWithTraitsAndReplyWithResult()
/external/mesa3d/src/gallium/drivers/llvmpipe/
Dlp_rast.c96 lp_rast_tile_begin(struct lp_rasterizer_task *task, in lp_rast_tile_begin()
137 lp_rast_clear_color(struct lp_rasterizer_task *task, in lp_rast_clear_color()
185 lp_rast_clear_zstencil(struct lp_rasterizer_task *task, in lp_rast_clear_zstencil()
306 lp_rast_shade_tile(struct lp_rasterizer_task *task, in lp_rast_shade_tile()
399 lp_rast_shade_tile_opaque(struct lp_rasterizer_task *task, in lp_rast_shade_tile_opaque()
420 lp_rast_shade_quads_mask_sample(struct lp_rasterizer_task *task, in lp_rast_shade_quads_mask_sample()
500 lp_rast_shade_quads_mask(struct lp_rasterizer_task *task, in lp_rast_shade_quads_mask()
517 lp_rast_begin_query(struct lp_rasterizer_task *task, in lp_rast_begin_query()
544 lp_rast_end_query(struct lp_rasterizer_task *task, in lp_rast_end_query()
573 lp_rast_set_state(struct lp_rasterizer_task *task, in lp_rast_set_state()
[all …]
/external/cronet/base/task/
Dthread_pool.cc26 bool PostTask(const Location& from_here, OnceClosure task) override { in PostTask()
48 bool ThreadPool::PostTask(const Location& from_here, OnceClosure task) { in PostTask()
54 OnceClosure task, in PostDelayedTask()
61 OnceClosure task, in PostTaskAndReply()
70 OnceClosure task) { in PostTask()
78 OnceClosure task, in PostDelayedTask()
87 OnceClosure task, in PostTaskAndReply()
/external/libchrome/base/android/java/src/org/chromium/base/
DThreadUtils.java75 FutureTask<Void> task = new FutureTask<Void>(r, null); in runOnUiThreadBlocking() local
110 FutureTask<T> task = new FutureTask<T>(c); in runOnUiThreadBlocking() local
126 public static <T> FutureTask<T> runOnUiThread(FutureTask<T> task) { in runOnUiThread()
167 public static <T> FutureTask<T> postOnUiThread(FutureTask<T> task) { in postOnUiThread()
178 public static void postOnUiThread(Runnable task) { in postOnUiThread()
190 public static void postOnUiThreadDelayed(Runnable task, long delayMillis) { in postOnUiThreadDelayed()
/external/tensorflow/tensorflow/core/data/service/
Dworker_impl.cc111 TaskDef Export(const TaskDef& task) { in Export()
202 for (auto& task : tasks) { in Stop() local
231 Task* task = nullptr; in GetElementResult() local
287 const TaskDef& task = request->task(); in ProcessTask() local
294 std::shared_ptr<Task>& task = tasks_[task_def.task_id()]; in ProcessTaskInternal() local
308 DataServiceWorkerImpl::Task& task) { in EnsureTaskInitialized()
398 void DataServiceWorkerImpl::StopTask(Task& task) TF_LOCKS_EXCLUDED(mu_) { in StopTask()
431 Task* task = it.second.get(); in GetWorkerTasks() local
520 for (const auto& task : tasks_) { in Heartbeat() local
537 for (const auto& task : response.new_tasks()) { in Heartbeat() local
[all …]
/external/skia/src/gpu/graphite/
DTaskGraph.cpp15 void TaskGraph::add(sk_sp<Task> task) { in add()
19 void TaskGraph::prepend(sk_sp<Task> task) { in prepend()
25 for (const auto& task: fTasks) { in prepareResources() local
37 for (const auto& task: fTasks) { in addCommands() local
/external/cronet/base/process/
Dprocess_metrics_mac.cc59 bool GetTaskInfo(mach_port_t task, task_basic_info_64* task_info_data) { in GetTaskInfo()
81 bool GetPowerInfo(mach_port_t task, task_power_info* power_info_data) { in GetPowerInfo()
93 double GetEnergyImpactInternal(mach_port_t task, uint64_t mach_time) { in GetEnergyImpactInternal()
122 mach_port_t task = TaskForPid(process_); in GetCumulativeCPUUsage() local
160 mach_port_t task = TaskForPid(process_); in GetPackageIdleWakeupsPerSecond() local
180 mach_port_t task = TaskForPid(process_); in GetIdleWakeupsPerSecond() local
254 mach_port_t task = MACH_PORT_NULL; in TaskForPid() local
322 MachVMRegionResult GetTopInfo(mach_port_t task, in GetTopInfo()
338 MachVMRegionResult GetBasicInfo(mach_port_t task, in GetBasicInfo()
/external/jacoco/org.jacoco.ant/src/org/jacoco/ant/
DCoverageTask.java57 public void addTask(final Task task) { in addTask()
119 public void enhanceTask(final Task task) { in enhanceTask()
141 public void enhanceTask(final Task task) { in enhanceTask()
157 public void addJvmArgs(final Task task) { in addJvmArgs()
198 void enhanceTask(Task task) throws BuildException; in enhanceTask()
/external/python/cpython3/Lib/asyncio/
Dbase_tasks.py8 def _task_repr_info(task): argument
25 def _task_get_stack(task, limit): argument
60 def _task_print_stack(task, limit, file): argument
/external/pthreadpool/src/
Dshim.c31 pthreadpool_task_1d_t task, in pthreadpool_parallelize_1d()
43 pthreadpool_task_1d_with_id_t task, in pthreadpool_parallelize_1d_with_uarch()
57 pthreadpool_task_1d_tile_1d_t task, in pthreadpool_parallelize_1d_tile_1d()
70 pthreadpool_task_2d_t task, in pthreadpool_parallelize_2d()
85 pthreadpool_task_2d_tile_1d_t task, in pthreadpool_parallelize_2d_tile_1d()
101 pthreadpool_task_2d_tile_2d_t task, in pthreadpool_parallelize_2d_tile_2d()
118 pthreadpool_task_2d_tile_2d_with_id_t task, in pthreadpool_parallelize_2d_tile_2d_with_uarch()
138 pthreadpool_task_3d_t task, in pthreadpool_parallelize_3d()
156 pthreadpool_task_3d_tile_1d_t task, in pthreadpool_parallelize_3d_tile_1d()
175 pthreadpool_task_3d_tile_2d_t task, in pthreadpool_parallelize_3d_tile_2d()
[all …]
/external/guava/guava/src/com/google/common/util/concurrent/
DForwardingListeningExecutorService.java43 public <T extends @Nullable Object> ListenableFuture<T> submit(Callable<T> task) { in submit()
48 public ListenableFuture<?> submit(Runnable task) { in submit()
54 Runnable task, @ParametricNullness T result) { in submit()

12345678910>>...33