Home
last modified time | relevance | path

Searched refs:RunAsync (Results 1 – 16 of 16) sorted by relevance

/external/chromium-trace/catapult/devil/devil/utils/
Dreraiser_thread_unittest.py104 results = reraiser_thread.RunAsync([])
108 results = reraiser_thread.RunAsync([lambda: 1])
112 a, b = reraiser_thread.RunAsync((lambda: 1, lambda: 2))
Dtimeout_retry_unittest.py73 return reraiser_thread.RunAsync((InnerInnerFunc,))[0]
Dreraiser_thread.py219 def RunAsync(funcs, watcher=None): function
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DQpsWorker.cs60 workerServer.RunAsync().Wait(); in Run()
64 private async Task RunAsync() in RunAsync() method in Grpc.IntegrationTesting.QpsWorker
/external/tensorflow/tensorflow/core/common_runtime/
Dexecutor.h105 virtual void RunAsync(const Args& args, DoneCallback done) = 0;
111 RunAsync(args, [&ret, &n](const Status& s) { in Run()
Dexecutor.cc315 void RunAsync(const Args& args, DoneCallback done) override;
856 void RunAsync(Executor::DoneCallback done);
1507 void ExecutorState::RunAsync(Executor::DoneCallback done) { in RunAsync() function in tensorflow::__anon675242740111::ExecutorState
2852 void ExecutorImpl::RunAsync(const Args& args, DoneCallback done) { in RunAsync() function in tensorflow::__anon675242740111::ExecutorImpl
2853 (new ExecutorState(args, this))->RunAsync(std::move(done)); in RunAsync()
Dfunction.cc1019 item->exec->RunAsync( in RunRemote()
1101 item->exec->RunAsync( in Run()
1156 item->exec->RunAsync(exec_args, std::move(done)); in Run()
Ddirect_session.cc654 item.executor->RunAsync(args, barrier->Get()); in RunInternal()
906 item.executor->RunAsync(args, barrier->Get()); in PRunSetup()
/external/chromium-trace/catapult/devil/devil/android/
Dcrash_handler_devicetest.py67 reraiser_thread.RunAsync([crasher, victim]))
Ddevice_utils.py1571 host_checksums, device_checksums = reraiser_thread.RunAsync((
1674 host_checksums, device_checksums = reraiser_thread.RunAsync((
/external/tensorflow/tensorflow/core/kernels/data/
Dcaptured_function.h79 void RunAsync(IteratorContext* ctx, std::vector<Tensor>&& args,
Dparallel_map_dataset_op.cc255 instantiated_captured_func_->RunAsync( in MapFunc()
Dsingle_threaded_executor.cc160 void RunAsync(const Args& args, DoneCallback done) override { in RunAsync() function in tensorflow::data::__anon94ff5ae60111::SingleThreadedExecutorImpl
Dcaptured_function.cc409 void InstantiatedCapturedFunction::RunAsync( in RunAsync() function in tensorflow::data::InstantiatedCapturedFunction
/external/tensorflow/tensorflow/core/distributed_runtime/
Dgraph_mgr.cc516 unit.root->RunAsync(args, barrier->Get()); in StartParallelExecutors()
/external/tensorflow/tensorflow/core/kernels/data/experimental/
Dmap_and_batch_dataset_op.cc100 instantiated_captured_func->RunAsync( in MakeDataset()