Searched refs:thread_factory (Results 1 – 8 of 8) sorted by relevance
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | unbounded_thread_pool_test.cc | 28 auto thread_factory = pool.get_thread_factory(); in TEST() local
36 threads.push_back(thread_factory->StartThread("", [=, &i, in TEST()
37 &thread_factory]() { in TEST()
41 thread_factory->StartThread("", [&i]() { ++i; })); in TEST()
53 auto thread_factory = pool.get_thread_factory(); in TEST() local
65 threads.push_back(thread_factory->StartThread("", [&bc, &n]() { in TEST()
|
| D | iterator_ops.cc | 122 params.thread_factory = unbounded_thread_pool_.get_thread_factory(); in GetNext()
210 params.thread_factory = unbounded_thread_pool_.get_thread_factory(); in Restore()
245 params.thread_factory = unbounded_thread_pool_.get_thread_factory(); in SetIteratorFromDataset()
|
| D | multi_device_iterator_ops.cc | 109 params.thread_factory = unbounded_thread_pool_.get_thread_factory(); in GetNextFromShard()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-newthread.hpp | 14 typedef std::function<std::thread(std::function<void()>)> thread_factory; typedef
77 new_worker(composite_subscription cs, thread_factory& tf) in new_worker()
147 mutable thread_factory factory;
156 explicit new_thread(thread_factory tf) in new_thread()
177 inline scheduler make_new_thread(thread_factory tf) { in make_new_thread()
|
| D | rx-eventloop.hpp | 63 mutable thread_factory factory;
82 explicit event_loop(thread_factory tf) in event_loop()
110 inline scheduler make_event_loop(thread_factory tf) { in make_event_loop()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | dataset.h | 353 thread_factory(ctx->thread_factory()), in Params()
426 std::shared_ptr<ThreadFactory> thread_factory = nullptr; member
476 const std::shared_ptr<ThreadFactory>& thread_factory() { in thread_factory() function
477 return params_.thread_factory; in thread_factory()
501 if (params_.thread_factory) { in StartThread()
502 return params_.thread_factory->StartThread(name, std::move(fn)); in StartThread()
|
| D | BUILD | 93 "thread_factory.h",
242 "thread_factory.h",
431 "thread_factory.h",
|
| /external/tensorflow/tensorflow/core/ |
| D | BUILD | 465 "//tensorflow/core/framework:thread_factory.h",
|