| /dports/databases/mariadb105-client/mariadb-10.5.15/sql/ |
| H A D | threadpool_generic.cc | 646 if (!thread_group->listener && !thread_group->io_event_count) in check_stall()
682 if (!is_queue_empty(thread_group) && !thread_group->queue_event_count) in check_stall()
885 thread_group->pthread_attr, worker_main, thread_group); in create_worker()
960 if (thread_group->thread_count > thread_group->connection_count) in wake_or_create_thread()
1000 queue_init(thread_group); in thread_group_init()
1291 (!is_queue_empty(thread_group) || !thread_group->listener)) in wait_begin()
1332 thread_group_t *thread_group= connection->thread_group; in add() local
1399 thread_group(0), in TP_connection_generic()
1425 thread_group=group; in TP_connection_generic()
1554 this_thread.thread_group= thread_group; in worker_main()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/sql/ |
| H A D | threadpool_generic.cc | 646 if (!thread_group->listener && !thread_group->io_event_count) in check_stall()
682 if (!is_queue_empty(thread_group) && !thread_group->queue_event_count) in check_stall()
885 thread_group->pthread_attr, worker_main, thread_group); in create_worker()
960 if (thread_group->thread_count > thread_group->connection_count) in wake_or_create_thread()
1000 queue_init(thread_group); in thread_group_init()
1291 (!is_queue_empty(thread_group) || !thread_group->listener)) in wait_begin()
1332 thread_group_t *thread_group= connection->thread_group; in add() local
1399 thread_group(0), in TP_connection_generic()
1425 thread_group=group; in TP_connection_generic()
1554 this_thread.thread_group= thread_group; in worker_main()
[all …]
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/ |
| H A D | threadpool_unix.cc | 120 thread_group_t *thread_group; member
432 return (thread_group->active_thread_count + thread_group->waiting_thread_count in too_many_busy_threads()
629 if (!thread_group->listener && !thread_group->io_event_count) in check_stall()
665 if (!thread_group->queue_event_count && !queues_are_empty(thread_group)) in check_stall()
889 thread_group->pthread_attr, worker_main, thread_group); in create_worker()
950 if (thread_group->shutdown) in wake_or_create_thread()
956 if (thread_group->thread_count > thread_group->connection_count) in wake_or_create_thread()
993 thread_group->pollfd= -1; in thread_group_init()
1277 (!queues_are_empty(thread_group) || !thread_group->listener)) in wait_begin()
1603 this_thread.thread_group= thread_group; in worker_main()
[all …]
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/ |
| H A D | threadpool_unix.cc | 120 thread_group_t *thread_group; member
432 return (thread_group->active_thread_count + thread_group->waiting_thread_count in too_many_busy_threads()
629 if (!thread_group->listener && !thread_group->io_event_count) in check_stall()
665 if (!thread_group->queue_event_count && !queues_are_empty(thread_group)) in check_stall()
889 thread_group->pthread_attr, worker_main, thread_group); in create_worker()
950 if (thread_group->shutdown) in wake_or_create_thread()
956 if (thread_group->thread_count > thread_group->connection_count) in wake_or_create_thread()
993 thread_group->pollfd= -1; in thread_group_init()
1277 (!queues_are_empty(thread_group) || !thread_group->listener)) in wait_begin()
1603 this_thread.thread_group= thread_group; in worker_main()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/sql/ |
| H A D | threadpool_unix.cc | 118 thread_group_t *thread_group; member
422 return (thread_group->active_thread_count + thread_group->waiting_thread_count in too_many_busy_threads()
627 if (!thread_group->listener && !thread_group->io_event_count) in check_stall()
663 if (!thread_group->queue_event_count && !queues_are_empty(thread_group)) in check_stall()
887 thread_group->pthread_attr, worker_main, thread_group); in create_worker()
948 if (thread_group->shutdown) in wake_or_create_thread()
954 if (thread_group->thread_count > thread_group->connection_count) in wake_or_create_thread()
989 thread_group->pollfd= -1; in thread_group_init()
1272 (!queues_are_empty(thread_group) || !thread_group->listener)) in wait_begin()
1617 this_thread.thread_group= thread_group; in worker_main()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/ |
| H A D | threadpool_unix.cc | 118 thread_group_t *thread_group; member
422 return (thread_group->active_thread_count + thread_group->waiting_thread_count in too_many_busy_threads()
627 if (!thread_group->listener && !thread_group->io_event_count) in check_stall()
663 if (!thread_group->queue_event_count && !queues_are_empty(thread_group)) in check_stall()
887 thread_group->pthread_attr, worker_main, thread_group); in create_worker()
948 if (thread_group->shutdown) in wake_or_create_thread()
954 if (thread_group->thread_count > thread_group->connection_count) in wake_or_create_thread()
989 thread_group->pollfd= -1; in thread_group_init()
1272 (!queues_are_empty(thread_group) || !thread_group->listener)) in wait_begin()
1617 this_thread.thread_group= thread_group; in worker_main()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/sql/ |
| H A D | threadpool_unix.cc | 118 thread_group_t *thread_group; member
422 return (thread_group->active_thread_count + thread_group->waiting_thread_count in too_many_busy_threads()
627 if (!thread_group->listener && !thread_group->io_event_count) in check_stall()
663 if (!thread_group->queue_event_count && !queues_are_empty(thread_group)) in check_stall()
887 thread_group->pthread_attr, worker_main, thread_group); in create_worker()
948 if (thread_group->shutdown) in wake_or_create_thread()
954 if (thread_group->thread_count > thread_group->connection_count) in wake_or_create_thread()
989 thread_group->pollfd= -1; in thread_group_init()
1272 (!queues_are_empty(thread_group) || !thread_group->listener)) in wait_begin()
1617 this_thread.thread_group= thread_group; in worker_main()
[all …]
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/ |
| H A D | threadpool_unix.cc | 120 thread_group_t *thread_group; member
432 return (thread_group->active_thread_count + thread_group->waiting_thread_count in too_many_busy_threads()
629 if (!thread_group->listener && !thread_group->io_event_count) in check_stall()
665 if (!thread_group->queue_event_count && !queues_are_empty(thread_group)) in check_stall()
889 thread_group->pthread_attr, worker_main, thread_group); in create_worker()
950 if (thread_group->shutdown) in wake_or_create_thread()
956 if (thread_group->thread_count > thread_group->connection_count) in wake_or_create_thread()
993 thread_group->pollfd= -1; in thread_group_init()
1277 (!queues_are_empty(thread_group) || !thread_group->listener)) in wait_begin()
1603 this_thread.thread_group= thread_group; in worker_main()
[all …]
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/sql/ |
| H A D | threadpool_generic.cc | 711 if (!thread_group->listener && !thread_group->io_event_count) in check_stall()
747 if (!is_queue_empty(thread_group) && !thread_group->queue_event_count) in check_stall()
951 thread_group->pthread_attr, worker_main, thread_group); in create_worker()
1018 if (thread_group->thread_count > thread_group->connection_count) in wake_or_create_thread()
1057 queue_init(thread_group); in thread_group_init()
1340 (!is_queue_empty(thread_group) || !thread_group->listener)) in wait_begin()
1383 thread_group_t *thread_group= connection->thread_group; in add() local
1444 thread_group(0), in TP_connection_generic()
1468 thread_group=group; in TP_connection_generic()
1597 this_thread.thread_group= thread_group; in worker_main()
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/sql/ |
| H A D | threadpool_generic.cc | 711 if (!thread_group->listener && !thread_group->io_event_count) in check_stall()
747 if (!is_queue_empty(thread_group) && !thread_group->queue_event_count) in check_stall()
951 thread_group->pthread_attr, worker_main, thread_group); in create_worker()
1018 if (thread_group->thread_count > thread_group->connection_count) in wake_or_create_thread()
1057 queue_init(thread_group); in thread_group_init()
1340 (!is_queue_empty(thread_group) || !thread_group->listener)) in wait_begin()
1383 thread_group_t *thread_group= connection->thread_group; in add() local
1444 thread_group(0), in TP_connection_generic()
1468 thread_group=group; in TP_connection_generic()
1597 this_thread.thread_group= thread_group; in worker_main()
[all …]
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/sql/ |
| H A D | threadpool_generic.cc | 710 if (!thread_group->listener && !thread_group->io_event_count) in check_stall()
746 if (!is_queue_empty(thread_group) && !thread_group->queue_event_count) in check_stall()
950 thread_group->pthread_attr, worker_main, thread_group); in create_worker()
1017 if (thread_group->thread_count > thread_group->connection_count) in wake_or_create_thread()
1056 queue_init(thread_group); in thread_group_init()
1339 (!is_queue_empty(thread_group) || !thread_group->listener)) in wait_begin()
1382 thread_group_t *thread_group= connection->thread_group; in add() local
1440 thread_group(0), in TP_connection_generic()
1464 thread_group=group; in TP_connection_generic()
1593 this_thread.thread_group= thread_group; in worker_main()
[all …]
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/sql/ |
| H A D | threadpool_generic.cc | 710 if (!thread_group->listener && !thread_group->io_event_count) in check_stall()
746 if (!is_queue_empty(thread_group) && !thread_group->queue_event_count) in check_stall()
950 thread_group->pthread_attr, worker_main, thread_group); in create_worker()
1017 if (thread_group->thread_count > thread_group->connection_count) in wake_or_create_thread()
1056 queue_init(thread_group); in thread_group_init()
1339 (!is_queue_empty(thread_group) || !thread_group->listener)) in wait_begin()
1382 thread_group_t *thread_group= connection->thread_group; in add() local
1440 thread_group(0), in TP_connection_generic()
1464 thread_group=group; in TP_connection_generic()
1593 this_thread.thread_group= thread_group; in worker_main()
[all …]
|
| /dports/misc/py-tvm/incubator-tvm-0.6.1/3rdparty/dmlc-core/test/unittest/ |
| H A D | unittest_thread_group.cc | 67 thread_group.reset(); in TEST()
82 thread_group.reset(); in TEST()
97 thread_group.reset(); in TEST()
112 thread_group.reset(); in TEST()
149 thread_group->request_shutdown_all(false); in TEST()
151 thread_group->join_all(); in TEST()
202 thread_group->request_shutdown_all(true); in TEST()
204 thread_group->join_all(); in TEST()
222 thread_group.get(), in TEST()
235 thread_group->request_shutdown_all(); in TEST()
[all …]
|
| /dports/devel/dmlc-core/dmlc-core-0.3-123-gb3a4c71/test/unittest/ |
| H A D | unittest_thread_group.cc | 67 thread_group.reset(); in TEST()
82 thread_group.reset(); in TEST()
97 thread_group.reset(); in TEST()
112 thread_group.reset(); in TEST()
149 thread_group->request_shutdown_all(false); in TEST()
151 thread_group->join_all(); in TEST()
202 thread_group->request_shutdown_all(true); in TEST()
204 thread_group->join_all(); in TEST()
222 thread_group.get(), in TEST()
235 thread_group->request_shutdown_all(); in TEST()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/devil/devil/utils/ |
| H A D | timeout_retry.py | 62 thread_group = reraiser_thread.CurrentThreadGroup()
63 while thread_group:
64 if isinstance(thread_group, TimeoutRetryThreadGroup):
65 return thread_group
66 thread_group = thread_group.blocked_parent_thread_group
158 thread_group = TimeoutRetryThreadGroup(timeout, threads=[child_thread])
159 thread_group.StartAll(will_block=True)
161 thread_group.JoinAll(
162 watcher=thread_group.GetWatcher(),
165 if thread_group.IsAlive():
[all …]
|
| /dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/lib/thread/ |
| H A D | thread_group.cc | 20 thread_group::thread_group() {} in thread_group() function in gr::thread::thread_group
22 thread_group::~thread_group() in ~thread_group()
35 boost::thread* thread_group::create_thread(const boost::function0<void>& threadfunc) in create_thread()
44 void thread_group::add_thread(boost::thread* thrd) in add_thread()
58 void thread_group::remove_thread(boost::thread* thrd) in remove_thread()
72 void thread_group::join_all() in join_all()
82 void thread_group::interrupt_all() in interrupt_all()
93 size_t thread_group::size() const in size()
|
| /dports/lang/ruby26/ruby-2.6.9/spec/ruby/core/threadgroup/ |
| H A D | enclosed_spec.rb | 5 thread_group = ThreadGroup.new
6 thread_group.enclosed?.should be_false
10 thread_group = ThreadGroup.new
11 thread_group.enclose
12 thread_group.enclosed?.should be_true
|
| /dports/devel/cpp-netlib/cpp-netlib-cpp-netlib-0.13.0-final/boost/network/utils/ |
| H A D | thread_group.hpp | 19 class thread_group { class
21 thread_group(thread_group const&);
22 thread_group& operator=(thread_group const&);
25 thread_group() {} in thread_group() function in boost::network::utils::thread_group
26 ~thread_group() {} in ~thread_group()
|
| /dports/games/spring/spring_98.0/rts/System/ |
| H A D | ThreadPool.cpp | 20 static std::deque<void*> thread_group; variable
66 return (thread_group.size() + 1); in GetNumThreads()
71 return !thread_group.empty(); in HasThreads()
217 thread_group.push_back(new COffscreenGLThread(boost::bind(&WorkerLoop, i))); in SetThreadCount()
230 thread_group.push_back(new boost::thread(boost::bind(&WorkerLoop, i))); in SetThreadCount()
235 assert(!thread_group.empty()); in SetThreadCount()
242 auto th = reinterpret_cast<COffscreenGLThread*>(thread_group.back()); in SetThreadCount()
248 auto th = reinterpret_cast<boost::thread*>(thread_group.back()); in SetThreadCount()
252 thread_group.pop_back(); in SetThreadCount()
256 assert(thread_group.empty()); in SetThreadCount()
[all …]
|
| /dports/games/frogatto/frogatto-1.3.1/MacOSJet/boost/include/boost/thread/detail/ |
| H A D | thread_group.hpp | 21 class thread_group class
24 thread_group(thread_group const&);
25 thread_group& operator=(thread_group const&);
27 thread_group() {} in thread_group() function in boost::thread_group
28 ~thread_group() in ~thread_group()
|
| /dports/databases/p5-Tie-LevelDB/Tie-LevelDB-0.07/boost_1_47/boost/thread/detail/ |
| H A D | thread_group.hpp | 21 class thread_group class
24 thread_group(thread_group const&);
25 thread_group& operator=(thread_group const&);
27 thread_group() {} in thread_group() function in boost::thread_group
28 ~thread_group() in ~thread_group()
|
| /dports/devel/rpclib/rpclib-2.2.1/include/rpc/detail/ |
| H A D | thread_group.h | 12 class thread_group {
14 thread_group() {} in thread_group() function
15 thread_group(thread_group const &) = delete;
31 ~thread_group() { join_all(); } in ~thread_group()
|
| /dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/deps/rpclib/include/rpc/detail/ |
| H A D | thread_group.h | 12 class thread_group {
14 thread_group() {} in thread_group() function
15 thread_group(thread_group const &) = delete;
31 ~thread_group() { join_all(); } in ~thread_group()
|
| /dports/math/suitesparse-klu/SuiteSparse-5.10.1/GraphBLAS/CUDA/templates/ |
| H A D | cooperative_groups.h | 67 class thread_group
70 …friend _CG_QUALIFIER thread_group tiled_partition(const thread_group& parent, unsigned int tilesz);
86 _CG_QUALIFIER thread_group operator=(const thread_group& src);
106 _CG_QUALIFIER thread_group this_thread() in this_thread()
108 thread_group g = thread_group(__internal::Coalesced); in this_thread()
270 class thread_block : public thread_group
273 …friend _CG_QUALIFIER thread_group tiled_partition(const thread_group& parent, unsigned int tilesz);
295 thread_group tile = thread_group(__internal::CoalescedTile); in _get_tiled_threads()
349 class coalesced_group : public thread_group
352 …friend _CG_QUALIFIER thread_group tiled_partition(const thread_group& parent, unsigned int tilesz);
[all …]
|
| /dports/math/suitesparse-btf/SuiteSparse-5.10.1/GraphBLAS/CUDA/templates/ |
| H A D | cooperative_groups.h | 67 class thread_group
70 …friend _CG_QUALIFIER thread_group tiled_partition(const thread_group& parent, unsigned int tilesz);
86 _CG_QUALIFIER thread_group operator=(const thread_group& src);
106 _CG_QUALIFIER thread_group this_thread() in this_thread()
108 thread_group g = thread_group(__internal::Coalesced); in this_thread()
270 class thread_block : public thread_group
273 …friend _CG_QUALIFIER thread_group tiled_partition(const thread_group& parent, unsigned int tilesz);
295 thread_group tile = thread_group(__internal::CoalescedTile); in _get_tiled_threads()
349 class coalesced_group : public thread_group
352 …friend _CG_QUALIFIER thread_group tiled_partition(const thread_group& parent, unsigned int tilesz);
[all …]
|