/dports/lang/mono/mono-5.10.1.57/mono/tests/ |
H A D | threadpool1.cs | 9 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 D | threadpool.cs | 16 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 D | ThreadPoolTest.cs | 124 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 D | RequestQueue.cs | 151 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 D | ThreadPool.Portable.cs | 328 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 D | ThreadPool.Windows.cs | 247 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 D | s_async.cpp | 48 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 D | s_async.cpp | 41 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 D | servr_uk.c | 106 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 D | servr_uu.c | 104 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 D | server_test.c | 139 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 D | servr_kk.c | 103 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 D | servr_ku.c | 104 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 D | server_test.c | 139 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 D | servr_kk.c | 103 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 D | servr_ku.c | 104 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 D | servr_uk.c | 106 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 D | servr_uu.c | 104 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 D | TaskManager.java | 36 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 D | ThriftServer.java | 254 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 D | System.Threading.ThreadPool.cs | 21 …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 D | HThreadedSelectorServerArgs.java | 75 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 D | devdiscover.in | 40 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 D | Network.cpp | 302 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 D | rarefact.cpp | 101 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()
|