Home
last modified time | relevance | path

Searched refs:workerThreads (Results 1 – 25 of 195) sorted by relevance

12345678

/dports/lang/mono/mono-5.10.1.57/mono/tests/
H A Dthreadpool1.cs9 int workerThreads; in test_callback()
11 ThreadPool.GetAvailableThreads (out workerThreads, out completionPortThreads); in test_callback()
12 Console.WriteLine("test_casllback:" + state + "ATH: " + workerThreads); in test_callback()
19 int workerThreads; in Main()
23 ThreadPool.GetMaxThreads (out workerThreads, out completionPortThreads); in Main()
24 …Console.WriteLine ("workerThreads: {0} completionPortThreads: {1}", workerThreads, completionPortT… in Main()
26 ThreadPool.GetAvailableThreads (out workerThreads, out completionPortThreads); in Main()
37 ThreadPool.GetAvailableThreads (out workerThreads, out completionPortThreads); in Main()
38 if (workerThreads == 0) in Main()
40 } while (workerThreads == 0); in Main()
[all …]
H A Dthreadpool.cs16 int workerThreads; in Main()
19 ThreadPool.GetMaxThreads (out workerThreads, out completionPortThreads); in Main()
20 …Console.WriteLine ("workerThreads: {0} completionPortThreads: {1}", workerThreads, completionPortT… in Main()
22 ThreadPool.GetAvailableThreads (out workerThreads, out completionPortThreads); in Main()
23 …Console.WriteLine ("workerThreads: {0} completionPortThreads: {1}", workerThreads, completionPortT… in Main()
/dports/lang/mono/mono-5.10.1.57/mcs/class/corlib/Test/System.Threading/
H A DThreadPoolTest.cs124 int workerThreads, completionPortThreads; in SetAndGetMinThreads()
127 ThreadPool.GetMinThreads (out workerThreads, out completionPortThreads); in SetAndGetMinThreads()
128 Assert.IsTrue (workerThreads > 0, "#1"); in SetAndGetMinThreads()
131 workerThreads_new = workerThreads == 1 ? 2 : 1; in SetAndGetMinThreads()
135 ThreadPool.GetMinThreads (out workerThreads, out completionPortThreads); in SetAndGetMinThreads()
136 Assert.IsTrue (workerThreads == workerThreads_new, "#3"); in SetAndGetMinThreads()
144 int workerThreads, completionPortThreads; in SetAndGetMaxThreads()
148 Assert.IsTrue (workerThreads > 0, "#1"); in SetAndGetMaxThreads()
156 Assert.IsTrue (workerThreads == workerThreads_new, "#3"); in SetAndGetMaxThreads()
182 int i, workerThreads, completionPortThreads; in GetAvailableThreads()
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Web/
H A DRequestQueue.cs151 int workerThreads, ioThreads; in GetRequestToExecute()
152 ThreadPool.GetAvailableThreads(out workerThreads, out ioThreads); in GetRequestToExecute()
156 … freeThreads = workerThreads; // ignore IO threads to avoid starvation from Indigo TCP requests in GetRequestToExecute()
158 freeThreads = (ioThreads > workerThreads) ? workerThreads : ioThreads; in GetRequestToExecute()
209 int workerThreads, ioThreads; in ScheduleMoreWorkIfNeeded()
210 ThreadPool.GetAvailableThreads(out workerThreads, out ioThreads); in ScheduleMoreWorkIfNeeded()
211 if (workerThreads < _minLocalFreeThreads) in ScheduleMoreWorkIfNeeded()
236 int workerThreads, ioThreads; in WorkItemCallback()
237 ThreadPool.GetAvailableThreads(out workerThreads, out ioThreads); in WorkItemCallback()
240 if (workerThreads < _minLocalFreeThreads) in WorkItemCallback()
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corert/src/System.Private.CoreLib/src/System/Threading/
H A DThreadPool.Portable.cs328 public static bool SetMaxThreads(int workerThreads, int completionPortThreads) in SetMaxThreads() argument
330 if (workerThreads < 0 || completionPortThreads < 0) in SetMaxThreads()
334 return ClrThreadPool.ThreadPoolInstance.SetMaxThreads(workerThreads); in SetMaxThreads()
337 public static void GetMaxThreads(out int workerThreads, out int completionPortThreads) in GetMaxThreads() argument
341 workerThreads = ClrThreadPool.ThreadPoolInstance.GetMaxThreads(); in GetMaxThreads()
345 public static bool SetMinThreads(int workerThreads, int completionPortThreads) in SetMinThreads() argument
347 if (workerThreads < 0 || completionPortThreads < 0) in SetMinThreads()
351 return ClrThreadPool.ThreadPoolInstance.SetMinThreads(workerThreads); in SetMinThreads()
354 public static void GetMinThreads(out int workerThreads, out int completionPortThreads) in GetMinThreads() argument
357 workerThreads = ClrThreadPool.ThreadPoolInstance.GetMinThreads(); in GetMinThreads()
[all …]
H A DThreadPool.Windows.cs247 public static bool SetMaxThreads(int workerThreads, int completionPortThreads) in SetMaxThreads() argument
253 public static void GetMaxThreads(out int workerThreads, out int completionPortThreads) in GetMaxThreads() argument
257 workerThreads = MaxThreadCount; in GetMaxThreads()
261 public static bool SetMinThreads(int workerThreads, int completionPortThreads) in SetMinThreads() argument
267 public static void GetMinThreads(out int workerThreads, out int completionPortThreads) in GetMinThreads() argument
269 workerThreads = 0; in GetMinThreads()
273 public static void GetAvailableThreads(out int workerThreads, out int completionPortThreads) in GetAvailableThreads() argument
278 workerThreads = availableThreads; in GetAvailableThreads()
/dports/games/freeminer/freeminer-0.4.10.4/src/script/cpp_api/
H A Ds_async.cpp48 for (std::vector<AsyncWorkerThread *>::iterator it = workerThreads.begin(); in ~AsyncEngine()
49 it != workerThreads.end(); it++) { in ~AsyncEngine()
55 for (std::vector<AsyncWorkerThread *>::iterator it = workerThreads.begin(); in ~AsyncEngine()
56 it != workerThreads.end(); it++) { in ~AsyncEngine()
61 for (std::vector<AsyncWorkerThread *>::iterator it = workerThreads.begin(); in ~AsyncEngine()
62 it != workerThreads.end(); it++) { in ~AsyncEngine()
67 for (std::vector<AsyncWorkerThread *>::iterator it = workerThreads.begin(); in ~AsyncEngine()
68 it != workerThreads.end(); it++) { in ~AsyncEngine()
76 workerThreads.clear(); in ~AsyncEngine()
96 workerThreads.push_back(toAdd); in initialize()
/dports/games/minetest/minetest-5.4.1/src/script/cpp_api/
H A Ds_async.cpp41 for (AsyncWorkerThread *workerThread : workerThreads) { in ~AsyncEngine()
47 for (std::vector<AsyncWorkerThread *>::iterator it = workerThreads.begin(); in ~AsyncEngine()
48 it != workerThreads.end(); ++it) { in ~AsyncEngine()
53 for (AsyncWorkerThread *workerThread : workerThreads) { in ~AsyncEngine()
58 for (AsyncWorkerThread *workerThread : workerThreads) { in ~AsyncEngine()
65 workerThreads.clear(); in ~AsyncEngine()
82 workerThreads.push_back(toAdd); in initialize()
/dports/lang/spidermonkey60/firefox-60.9.0/nsprpub/pr/tests/
H A Dservr_uk.c106 PRInt32 workerThreads; variable
156 if (workerThreadsBusy == workerThreads && workerThreads<1) {
158 if (workerThreadsBusy == workerThreads) {
161 if (workerThreadsBusy == workerThreads) {
174 if (debug_mode) printf("Error creating client thread %d\n", workerThreads);
176 PR_AtomicIncrement(&workerThreads);
177 if (debug_mode) DPRINTF("\tServer creates worker (%d)\n", workerThreads);
260 workerThreads = 0;
279 PR_AtomicIncrement(&workerThreads);
H A Dservr_uu.c104 PRInt32 workerThreads; variable
154 if (workerThreadsBusy == workerThreads && workerThreads<1) {
156 if (workerThreadsBusy == workerThreads) {
160 if (workerThreadsBusy == workerThreads) {
173 if (debug_mode) printf("Error creating client thread %d\n", workerThreads);
175 PR_AtomicIncrement(&workerThreads);
176 if (debug_mode) DPRINTF("\tServer creates worker (%d)\n", workerThreads);
259 workerThreads = 0;
278 PR_AtomicIncrement(&workerThreads);
H A Dserver_test.c139 PRInt32 workerThreads; variable
189 if (workerThreadsBusy == workerThreads && workerThreads<1) {
191 if (workerThreadsBusy == workerThreads) {
194 if (workerThreadsBusy == workerThreads) {
207 if (debug_mode) printf("Error creating client thread %d\n", workerThreads);
209 PR_AtomicIncrement(&workerThreads);
210 if (debug_mode) DPRINTF("\tServer creates worker (%d)\n", workerThreads);
293 workerThreads = 0;
312 PR_AtomicIncrement(&workerThreads);
H A Dservr_kk.c103 PRInt32 workerThreads; variable
153 if (workerThreadsBusy == workerThreads && workerThreads<1) {
155 if (workerThreadsBusy == workerThreads) {
158 if (workerThreadsBusy == workerThreads) {
171 if (debug_mode) printf("Error creating client thread %d\n", workerThreads);
173 PR_AtomicIncrement(&workerThreads);
174 if (debug_mode) DPRINTF("\tServer creates worker (%d)\n", workerThreads);
257 workerThreads = 0;
276 PR_AtomicIncrement(&workerThreads);
H A Dservr_ku.c104 PRInt32 workerThreads; variable
154 if (workerThreadsBusy == workerThreads && workerThreads<1) {
156 if (workerThreadsBusy == workerThreads) {
159 if (workerThreadsBusy == workerThreads) {
172 if (debug_mode) printf("Error creating client thread %d\n", workerThreads);
174 PR_AtomicIncrement(&workerThreads);
175 if (debug_mode) DPRINTF("\tServer creates worker (%d)\n", workerThreads);
258 workerThreads = 0;
277 PR_AtomicIncrement(&workerThreads);
/dports/www/firefox-legacy/firefox-52.8.0esr/nsprpub/pr/tests/
H A Dserver_test.c139 PRInt32 workerThreads; variable
189 if (workerThreadsBusy == workerThreads && workerThreads<1) {
191 if (workerThreadsBusy == workerThreads) {
194 if (workerThreadsBusy == workerThreads) {
207 if (debug_mode) printf("Error creating client thread %d\n", workerThreads);
209 PR_AtomicIncrement(&workerThreads);
210 if (debug_mode) DPRINTF("\tServer creates worker (%d)\n", workerThreads);
293 workerThreads = 0;
312 PR_AtomicIncrement(&workerThreads);
H A Dservr_kk.c103 PRInt32 workerThreads; variable
153 if (workerThreadsBusy == workerThreads && workerThreads<1) {
155 if (workerThreadsBusy == workerThreads) {
158 if (workerThreadsBusy == workerThreads) {
171 if (debug_mode) printf("Error creating client thread %d\n", workerThreads);
173 PR_AtomicIncrement(&workerThreads);
174 if (debug_mode) DPRINTF("\tServer creates worker (%d)\n", workerThreads);
257 workerThreads = 0;
276 PR_AtomicIncrement(&workerThreads);
H A Dservr_ku.c104 PRInt32 workerThreads; variable
154 if (workerThreadsBusy == workerThreads && workerThreads<1) {
156 if (workerThreadsBusy == workerThreads) {
159 if (workerThreadsBusy == workerThreads) {
172 if (debug_mode) printf("Error creating client thread %d\n", workerThreads);
174 PR_AtomicIncrement(&workerThreads);
175 if (debug_mode) DPRINTF("\tServer creates worker (%d)\n", workerThreads);
258 workerThreads = 0;
277 PR_AtomicIncrement(&workerThreads);
H A Dservr_uk.c106 PRInt32 workerThreads; variable
156 if (workerThreadsBusy == workerThreads && workerThreads<1) {
158 if (workerThreadsBusy == workerThreads) {
161 if (workerThreadsBusy == workerThreads) {
174 if (debug_mode) printf("Error creating client thread %d\n", workerThreads);
176 PR_AtomicIncrement(&workerThreads);
177 if (debug_mode) DPRINTF("\tServer creates worker (%d)\n", workerThreads);
260 workerThreads = 0;
279 PR_AtomicIncrement(&workerThreads);
H A Dservr_uu.c104 PRInt32 workerThreads; variable
154 if (workerThreadsBusy == workerThreads && workerThreads<1) {
156 if (workerThreadsBusy == workerThreads) {
160 if (workerThreadsBusy == workerThreads) {
173 if (debug_mode) printf("Error creating client thread %d\n", workerThreads);
175 PR_AtomicIncrement(&workerThreads);
176 if (debug_mode) DPRINTF("\tServer creates worker (%d)\n", workerThreads);
259 workerThreads = 0;
278 PR_AtomicIncrement(&workerThreads);
/dports/graphics/lightzone/LightZone-4.1.8-3-g36e87773/lightcrafts/src/com/lightcrafts/utils/thread/
H A DTaskManager.java36 final Thread[] workerThreads = new Thread[ numThreads ]; in TaskManager() local
38 workerThreads[i] = new Thread( this, "Task Manager Worker " + i ); in TaskManager()
39 workerThreads[i].setPriority( Thread.MIN_PRIORITY ); in TaskManager()
40 workerThreads[i].setDaemon( true ); in TaskManager()
41 workerThreads[i].start(); in TaskManager()
/dports/databases/hbase/hbase-1.2.1/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/
H A DThriftServer.java254 int workerThreads, in getTHsHaServer() argument
260 if (workerThreads > 0) { in getTHsHaServer()
262 serverArgs.minWorkerThreads(workerThreads).maxWorkerThreads(workerThreads); in getTHsHaServer()
265 workerThreads, metrics); in getTHsHaServer()
274 int workerThreads, ThriftMetrics metrics) { in createExecutor() argument
280 ThreadPoolExecutor pool = new ThreadPoolExecutor(workerThreads, workerThreads, in createExecutor()
303 if (workerThreads > 0) { in getTThreadPoolServer()
304 serverArgs.maxWorkerThreads(workerThreads); in getTThreadPoolServer()
338 int workerThreads = 0; in main() local
504 workerThreads, in main()
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.ThreadPool/ref/
H A DSystem.Threading.ThreadPool.cs21 …public static void GetAvailableThreads(out int workerThreads, out int completionPortThreads) { thr… in GetAvailableThreads() argument
22 …public static void GetMaxThreads(out int workerThreads, out int completionPortThreads) { throw nul… in GetMaxThreads() argument
23 …public static void GetMinThreads(out int workerThreads, out int completionPortThreads) { throw nul… in GetMinThreads() argument
32 … public static bool SetMaxThreads(int workerThreads, int completionPortThreads) { throw null; } in SetMaxThreads() argument
33 … public static bool SetMinThreads(int workerThreads, int completionPortThreads) { throw null; } in SetMinThreads() argument
/dports/databases/hbase/hbase-1.2.1/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/
H A DHThreadedSelectorServerArgs.java75 int workerThreads = conf.getInt( in readConf() local
85 .workerThreads(workerThreads) in readConf()
91 " workerThreads:" + workerThreads + in readConf()
/dports/net-mgmt/torrus/torrus-2.09/bin/
H A Ddevdiscover.in40 my $workerThreads = 0;
73 'threads=i' => \$workerThreads,
85 ($workerThreads > 1 and not $Torrus::Global::threadsEnabled ) )
212 if( $workerThreads > 1 )
244 foreach my $i ( 1..$workerThreads )
548 if( $workerThreads > 1 )
572 if( $workerThreads > 1 )
583 if( $workerThreads > 1 )
608 if( $workerThreads > 1 )
/dports/graphics/urho3d/Urho3D-1.7.1/Source/ThirdParty/kNet/src/
H A DNetwork.cpp302 for(size_t i = 0; i < workerThreads.size(); ++i) in GetOrCreateWorkerThread()
303 if (workerThreads[i]->NumConnections() + workerThreads[i]->NumServers() < maxConnectionsPerThread) in GetOrCreateWorkerThread()
304 return workerThreads[i]; in GetOrCreateWorkerThread()
309 workerThreads.push_back(workerThread); in GetOrCreateWorkerThread()
310 … "Created a new NetworkWorkerThread. There are now %d worker threads.", (int)workerThreads.size()); in GetOrCreateWorkerThread()
369 for(size_t i = 0; i < workerThreads.size(); ++i) in CloseWorkerThread()
370 if (workerThreads[i] == workerThread) in CloseWorkerThread()
373 std::swap(workerThreads[i], workerThreads[workerThreads.size()-1]); in CloseWorkerThread()
374 workerThreads.pop_back(); in CloseWorkerThread()
521 while(!workerThreads.empty()) in DeInit()
[all …]
/dports/biology/mothur/mothur-1.46.1/source/
H A Drarefact.cpp101 vector<std::thread*> workerThreads; in getCurve() local
113 workerThreads.push_back(new std::thread(singleDriver, dataBundle)); in getCurve()
122 workerThreads[i]->join(); in getCurve()
125 delete workerThreads[i]; in getCurve()
239 vector<std::thread*> workerThreads; in getSharedCurve() local
252 workerThreads.push_back(new std::thread(sharedDriver, dataBundle)); in getSharedCurve()
263 workerThreads[i]->join(); in getSharedCurve()
266 delete workerThreads[i]; in getSharedCurve()

12345678