| /dports/graphics/openimageio/oiio-Release-2.2.16.0/src/include/OpenImageIO/ |
| H A D | parallel.h | 30 parallel_options(int maxthreads = 0, SplitDir splitdir = Split_Y,
32 : maxthreads(maxthreads) in maxthreads() argument
37 parallel_options(string_view name, int maxthreads = 0,
39 : maxthreads(maxthreads) in maxthreads() function
55 if (maxthreads <= 0) in resolve()
56 maxthreads = pool->size() + 1; // pool size + caller in resolve()
58 maxthreads = 1; in resolve()
61 bool singlethread() const { return maxthreads == 1; } in singlethread()
63 int maxthreads = 0; // Max threads (0 = use all) variable
|
| /dports/graphics/py-openimageio/oiio-Release-2.2.16.0/src/include/OpenImageIO/ |
| H A D | parallel.h | 30 parallel_options(int maxthreads = 0, SplitDir splitdir = Split_Y,
32 : maxthreads(maxthreads) in maxthreads() function
37 parallel_options(string_view name, int maxthreads = 0,
39 : maxthreads(maxthreads) in maxthreads() function
55 if (maxthreads <= 0) in resolve()
56 maxthreads = pool->size() + 1; // pool size + caller in resolve()
58 maxthreads = 1; in resolve()
61 bool singlethread() const { return maxthreads == 1; } in singlethread()
63 int maxthreads = 0; // Max threads (0 = use all) variable
|
| /dports/mail/py-fuglu/fuglu-0.8.0/src/fuglu/ |
| H A D | threadpool.py | 28 def __init__(self, minthreads=1, maxthreads=20, queuesize=100): argument
33 self.maxthreads = maxthreads
35 assert self.maxthreads > self.minthreads
63 for _ in range(self.maxthreads):
78 self.minthreads, self.maxthreads, self.queuesize, self.checkinterval))
92 if numthreads > self.maxthreads:
93 diff = numthreads - self.maxthreads
106 if workload > 1 and numthreads < self.maxthreads:
|
| /dports/devel/py-twisted/Twisted-22.1.0/src/twisted/python/ |
| H A D | threadpool.py | 56 def __init__(self, minthreads=5, maxthreads=20, name=None): argument
70 assert minthreads <= maxthreads, "minimum is greater than maximum"
72 self.max = maxthreads
277 def adjustPoolsize(self, minthreads=None, maxthreads=None): argument
288 if maxthreads is None:
289 maxthreads = self.max
292 assert minthreads <= maxthreads, "minimum is greater than maximum"
295 self.max = maxthreads
|
| /dports/databases/hbase/hbase-1.2.1/bin/ |
| H A D | graceful_stop.sh | 50 maxthreads=1
61 --maxthreads) shift; maxthreads=$1; shift;;
99 … org.jruby.Main "$bin"/region_mover.rb --file=$filename $debug --maxthreads=$maxthreads unload $ho…
153 … org.jruby.Main "$bin"/region_mover.rb --file=$filename $debug --maxthreads=$maxthreads load $host…
|
| /dports/math/vtk6/VTK-6.2.0/ThirdParty/Twisted/twisted/python/ |
| H A D | threadpool.py | 52 def __init__(self, minthreads=5, maxthreads=20, name=None): argument
60 assert minthreads <= maxthreads, 'minimum is greater than maximum'
63 self.max = maxthreads
239 def adjustPoolsize(self, minthreads=None, maxthreads=None): argument
242 if maxthreads is None:
243 maxthreads = self.max
246 assert minthreads <= maxthreads, 'minimum is greater than maximum'
249 self.max = maxthreads
|
| /dports/print/texlive-base/texlive-20150521-source/utils/asymptote/ |
| H A D | fftw++.h | 234 static unsigned int maxthreads; variable
810 unsigned int threads=maxthreads)
816 unsigned int threads=maxthreads)
865 unsigned int Threads=maxthreads)
996 unsigned int threads=maxthreads)
1045 unsigned int threads=maxthreads)
1050 unsigned int threads=maxthreads)
1054 unsigned int threads=maxthreads)
1267 unsigned int threads=maxthreads)
1454 unsigned int threads=maxthreads)
[all …]
|
| /dports/comms/wsjtz/wsjtx/lib/ |
| H A D | timefft.f90 | 18 call timefft_opts(npatience,maxthreads,linplace,lcomplex,nfft,problem,nflags)
19 lthreading=maxthreads.ge.1
20 maxthreads=max(1,maxthreads)
54 do nthreads=1,maxthreads
|
| /dports/www/tntnet/tntnet-2.2.1/framework/common/ |
| H A D | tntnet.cpp | 80 maxthreads(TntConfig::it().maxThreads), in Tntnet()
95 maxthreads = config.maxThreads; in init()
189 if (maxthreads < minthreads) in run()
192 maxthreads = minthreads; in run()
238 if (Worker::getCountThreads() < maxthreads) in run()
245 log_info("max worker-threadcount " << maxthreads << " reached"); in run()
320 minthreads = maxthreads = 0; in timerTask()
|
| /dports/www/py-txrequests/txrequests-0.9.6/ |
| H A D | test_txrequests.py | 68 with Session(maxthreads=5) as session:
70 with Session(pool=ThreadPool(maxthreads=10)) as session:
72 with Session(pool=ThreadPool(maxthreads=10),
73 maxthreads=5) as session:
|
| /dports/net/mpich/mpich-3.4.3/modules/izem/test/perf/queue/ |
| H A D | thscale_mpb.c | 26 int maxthreads = omp_get_max_threads(); in run() local
31 for (nbuckets = 1; nbuckets <= maxthreads; nbuckets *= 2) { in run()
32 for (nthreads = 2; nthreads <= maxthreads; nthreads ++) { in run()
|
| /dports/www/py-txrequests/txrequests-0.9.6/txrequests/ |
| H A D | sessions.py | 30 def __init__(self, pool=None, minthreads=1, maxthreads=4, **kwargs): argument
43 pool = ThreadPool(minthreads=minthreads, maxthreads=maxthreads)
|
| /dports/math/asymptote/asymptote-2.67/ |
| H A D | fftw++.h | 171 static unsigned int maxthreads; variable
375 if(fftw::maxthreads > 1) {
661 unsigned int threads=maxthreads)
667 unsigned int threads=maxthreads)
706 if(fftw::maxthreads > 1) { in fftwblock()
878 unsigned int threads=maxthreads)
926 unsigned int threads=maxthreads)
1098 unsigned int threads=maxthreads)
1149 unsigned int threads=maxthreads)
1292 unsigned int threads=maxthreads)
[all …]
|
| /dports/www/tclhttpd/tclhttpd3.5.1/lib/ |
| H A D | thread.tcl | 38 set Thread(maxthreads) $max ;# Number of threads we can create
156 if {!$Thread(enable) || $Thread(maxthreads) == 0} {
160 if {[llength $Thread(threadlist)] < $Thread(maxthreads)} {
205 if {!$Thread(enable) || $Thread(maxthreads) == 0} {
209 if {[llength $Thread(threadlist)] < $Thread(maxthreads)} {
|
| /dports/math/lis/lis-2.0.30/test/ |
| H A D | spmvtest5.c | 56 LIS_INT nthreads, maxthreads; in main() local
115 maxthreads = omp_get_max_threads(); in main()
117 lis_printf(comm,"number of threads = %d\n", maxthreads); in main()
120 maxthreads = 1; in main()
|
| H A D | spmvtest4.c | 56 LIS_INT nthreads, maxthreads; in main() local
110 maxthreads = omp_get_max_threads(); in main()
112 lis_printf(comm,"number of threads = %d\n", maxthreads); in main()
115 maxthreads = 1; in main()
|
| H A D | spmvtest1.c | 57 LIS_INT nthreads, maxthreads; in main() local
117 maxthreads = omp_get_max_threads(); in main()
119 lis_printf(comm,"number of threads = %d\n", maxthreads); in main()
122 maxthreads = 1; in main()
|
| H A D | spmvtest3b.c | 57 LIS_INT nthreads,maxthreads; in main() local
120 maxthreads = omp_get_max_threads(); in main()
122 lis_printf(comm,"number of threads = %d\n", maxthreads); in main()
125 maxthreads = 1; in main()
|
| /dports/devel/staf/src/staf/services/stax/service/ |
| H A D | STAXParallelIterateActionFactory.java | 66 String maxthreads = null; in parseAction() local
93 maxthreads = STAXUtil.parseAndCompileForPython( in parseAction()
146 action.setMaxThreads(maxthreads); in parseAction()
|
| /dports/www/py-urlgrabber/urlgrabber-4.0.0/test/threading/ |
| H A D | batchgrabber.py | 47 def __init__(self, maxthreads=5, **kwargs): argument
48 self.maxthreads = 5
61 if self.queue and (len(self.threads) < self.maxthreads):
|
| /dports/www/tntnet/tntnet-2.2.1/framework/common/tnt/ |
| H A D | tntnet.h | 66 unsigned maxthreads; variable
143 unsigned getMaxThreads() const { return maxthreads; } in getMaxThreads()
145 void setMaxThreads(unsigned n) { maxthreads = n; } in setMaxThreads()
|
| /dports/graphics/openimageio/oiio-Release-2.2.16.0/src/libutil/ |
| H A D | benchmark.cpp | 184 int maxthreads, int total_iterations, int ntrials, in timed_thread_wedge() argument
194 if (nthreads > maxthreads) in timed_thread_wedge()
225 timed_thread_wedge(function_view<void(int)> task, int maxthreads, in timed_thread_wedge() argument
229 task, []() {}, []() {}, &std::cout, maxthreads, total_iterations, in timed_thread_wedge()
|
| /dports/graphics/py-openimageio/oiio-Release-2.2.16.0/src/libutil/ |
| H A D | benchmark.cpp | 184 int maxthreads, int total_iterations, int ntrials, in timed_thread_wedge() argument
194 if (nthreads > maxthreads) in timed_thread_wedge()
225 timed_thread_wedge(function_view<void(int)> task, int maxthreads, in timed_thread_wedge() argument
229 task, []() {}, []() {}, &std::cout, maxthreads, total_iterations, in timed_thread_wedge()
|
| /dports/lang/cython-devel/cython-2b1e743/tests/run/ |
| H A D | parallel.pyx | 18 cdef int maxthreads = openmp.omp_get_max_threads()
19 cdef int *buf = <int *> malloc(sizeof(int) * maxthreads)
30 for i in range(maxthreads):
|
| /dports/lang/cython/Cython-0.29.24/tests/run/ |
| H A D | parallel.pyx | 18 cdef int maxthreads = openmp.omp_get_max_threads()
19 cdef int *buf = <int *> malloc(sizeof(int) * maxthreads)
30 for i in range(maxthreads):
|