Searched refs:thread_factory (Results 1 – 7 of 7) sorted by relevance
28 auto thread_factory = pool.get_thread_factory(); in TEST() local33 auto thread = thread_factory->StartThread("", [&i]() { ++i; }); in TEST()42 auto thread_factory = pool.get_thread_factory(); in TEST() local50 threads.push_back(thread_factory->StartThread("", [&i]() { ++i; })); in TEST()60 auto thread_factory = pool.get_thread_factory(); in TEST() local68 threads.push_back(thread_factory->StartThread("", [&i]() { in TEST()81 auto thread_factory = pool.get_thread_factory(); in TEST() local89 threads.push_back(thread_factory->StartThread("", [&i, thread_factory]() { in TEST()93 thread_factory->StartThread("", [&i]() { ++i; })); in TEST()106 auto thread_factory = pool.get_thread_factory(); in TEST() local[all …]
83 params.thread_factory = unbounded_thread_pool_.get_thread_factory(); in GetNext()170 params.thread_factory = unbounded_thread_pool_.get_thread_factory(); in Restore()188 params.thread_factory = unbounded_thread_pool_.get_thread_factory(); in Restore()243 params.thread_factory = unbounded_thread_pool_.get_thread_factory(); in SetIteratorFromDataset()
101 params.thread_factory = unbounded_thread_pool_.get_thread_factory(); in GetNextFromShard()
14 typedef std::function<std::thread(std::function<void()>)> thread_factory; typedef67 new_worker(composite_subscription cs, thread_factory& tf) in new_worker()143 mutable thread_factory factory;152 explicit new_thread(thread_factory tf) in new_thread()173 inline scheduler make_new_thread(thread_factory tf) { in make_new_thread()
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()
293 thread_factory(ctx->thread_factory()) {} in Params()347 std::shared_ptr<ThreadFactory> thread_factory = nullptr; member384 const std::shared_ptr<ThreadFactory>& thread_factory() { in thread_factory() function385 return params_.thread_factory; in thread_factory()390 if (params_.thread_factory) { in StartThread()391 return params_.thread_factory->StartThread(name, std::move(fn)); in StartThread()
936 "framework/thread_factory.h",