Searched refs:workers (Results 1 - 25 of 30) sorted by relevance

12

/openjdk7/hotspot/src/share/vm/gc_implementation/g1/
H A Dg1RemSet.inline.hpp33 if (_g1->workers() != NULL) {
34 return _g1->workers()->total_workers();
H A DcollectionSetChooser.cpp165 assert(G1CollectedHeap::heap()->workers()->active_workers() > 0,
171 n_threads = MAX2(G1CollectedHeap::heap()->workers()->active_workers(),
H A Dg1HotCardCache.cpp48 _g1h->workers()->total_workers() : 1);
H A Dg1CollectedHeap.cpp81 // The number of GC workers is passed to heap_region_par_iterate_chunked().
1215 _g1->workers()->active_workers(),
1451 AdaptiveSizePolicy::calc_active_workers(workers()->total_workers(),
1452 workers()->active_workers(),
1455 n_workers == workers()->total_workers(),
1456 "If not dynamic should be using all the workers");
1457 workers()->set_active_workers(n_workers);
1469 workers()->active_workers() == workers()->total_workers(),
1470 "Unless dynamic should use total workers");
5292 G1STWRefProcTaskExecutor(G1CollectedHeap* g1h, FlexibleWorkGang* workers, RefToScanQueueSet *task_queues, int n_workers) argument
5437 G1ParPreserveCMReferentsTask(G1CollectedHeap* g1h,int workers, RefToScanQueueSet *task_queues) argument
[all...]
H A Dg1GCPhaseTimes.cpp228 void G1GCPhaseTimes::print_stats(int level, const char* str, double value, int workers) { argument
229 LineBuffer(level).append_and_print_cr("[%s: %.1lf ms, GC Workers: %d]", str, value, workers);
H A DconcurrentMark.cpp1015 // Calculates the number of active workers for a concurrent
1028 1, /* Minimum workers */
1039 // concurrent workers should be 0.
1532 assert( _g1h->workers()->active_workers() > 0,
1534 _n_workers = _g1h->workers()->active_workers();
1657 assert( _g1h->workers()->active_workers() > 0,
1659 _n_workers = _g1h->workers()->active_workers();
1775 _g1h->workers()->active_workers(),
1885 g1h->workers()->run_task(&g1_par_count_task);
1912 g1h->workers()
2221 G1CMRefProcTaskExecutor(G1CollectedHeap* g1h, ConcurrentMark* cm, WorkGang* workers, int n_workers) argument
[all...]
H A Dg1GCPhaseTimes.hpp51 assert(length > 0, "Must have some workers to store data for");
150 void print_stats(int level, const char* str, double value, int workers);
/openjdk7/jdk/test/com/sun/net/httpserver/bugs/6725892/
H A DTest.java228 Worker[] workers = new Worker[NUM*3];
230 workers[i*3] = new Worker (l, Worker.Mode.NORMAL);
231 workers[i*3+1] = new Worker (l, Worker.Mode.REQUEST);
232 workers[i*3+2] = new Worker (l, Worker.Mode.RESPONSE);
233 workers[i*3].start();
234 workers[i*3+1].start();
235 workers[i*3+2].start();
239 workers[i].join();
/openjdk7/hotspot/src/share/vm/gc_implementation/parallelScavenge/
H A DgcTaskManager.cpp377 GCTaskManager::GCTaskManager(uint workers) : argument
378 _workers(workers),
385 GCTaskManager::GCTaskManager(uint workers, NotifyDoneClosure* ndc) : argument
386 _workers(workers),
395 tty->print_cr("GCTaskManager::initialize: workers: %u", workers());
397 assert(workers() != 0, "no workers");
406 _resource_flag = NEW_C_HEAP_ARRAY(bool, workers(), mtGC);
409 // Distribute the workers amon
[all...]
H A DgcTaskManager.hpp324 // job not having all the expected active workers. For example if on
325 // job requests 4 active workers out of a total of 10 workers so the
326 // remaining 6 are "idled", if the next job requests 6 active workers
327 // but all 6 of the "idled" workers are still idle, then the next job
328 // will only get 4 active workers.
338 // 1-n be the active workers. This was undesirable because it required
340 // list of stacks equal in number to the active workers are filled
369 const uint _workers; // Number of workers.
373 uint _active_workers; // Number of active workers
387 create(uint workers) argument
390 create(uint workers, NotifyDoneClosure* ndc) argument
460 uint workers() const { function in class:GCTaskManager
[all...]
H A DpsCompactionManager.cpp81 uint parallel_gc_threads = PSParallelCompact::gc_task_manager()->workers();
121 assert(PSParallelCompact::gc_task_manager()->workers() != 0,
H A DpcTasks.cpp156 uint parallel_gc_threads = heap->gc_task_manager()->workers();
177 uint parallel_gc_threads = heap->gc_task_manager()->workers();
254 " empty (%d) use all workers %d",
332 "use all workers %d",
/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DThreadPoolExecutor.java331 * The workerCount is the number of workers that have been
337 * reported as the current size of the workers set.
445 * Lock held on access to workers set and related bookkeeping.
454 * ensuring workers set is stable while separately checking
463 private final HashSet<Worker> workers = new HashSet<Worker>(); field in class:ThreadPoolExecutor
529 * Core pool size is the minimum number of workers to keep alive
737 for (Worker w : workers)
753 for (Worker w : workers)
769 * enabled but there are still other workers. In this case, at
773 * workers sinc
[all...]
H A DForkJoinPool.java162 * split them into subtasks that may be stolen by other workers.
169 * decentralized control -- workers mostly take tasks from
190 * Recording Workers. Workers are recorded in the "workers" array
193 * structure to support index-based random steals by workers.
194 * Updates to the array recording new workers and unrecording
197 * and accessed directly by workers. To simplify index-based
201 * workers (which is unlikely to need further resizing during
204 * that contains all current workers. All worker thread creation
206 * terminated workers, and/or compensation for blocked
207 * workers
441 ForkJoinWorkerThread[] workers; field in class:ForkJoinPool
[all...]
H A DForkJoinWorkerThread.java131 * in that: (1) We only maintain dependency links across workers
133 * require a linear scan of workers array to locate stealers, but
232 * its workers array.
674 if (t != null || (ws = pool.workers) == null)
776 ForkJoinWorkerThread[] ws = pool.workers;
833 * some workers queue, steals and executes it.
840 ForkJoinWorkerThread[] ws = pool.workers;
870 * number of idle workers.
934 ForkJoinWorkerThread[] ws = p.workers;
/openjdk7/hotspot/src/share/vm/gc_implementation/parNew/
H A DparNewGeneration.cpp833 FlexibleWorkGang* workers = gch->workers(); local
834 assert(workers != NULL, "Need parallel worker threads.");
835 _state_set.reset(workers->active_workers(), _generation.promotion_failed());
838 workers->run_task(&rp_task);
846 FlexibleWorkGang* workers = gch->workers(); local
847 assert(workers != NULL, "Need parallel worker threads.");
849 workers->run_task(&enq_task);
931 FlexibleWorkGang* workers local
[all...]
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/orbutil/threadpool/
H A DThreadPoolImpl.java111 List<WorkerThread> workers = new ArrayList<>(); field in class:ThreadPoolImpl
157 copy = new ArrayList<>(workers);
320 workers.add(thread);
532 workers.remove(this);
/openjdk7/hotspot/src/share/vm/utilities/
H A DyieldingWorkgroup.hpp49 // Several instances of this class run in parallel as workers for a gang.
84 // and where the workers will periodically yield, usually
94 // gang workers waiting on the bench; in other words, the
162 YieldingFlexibleWorkGang(const char* name, uint workers,
173 // Run a task; returns when the task is done, or the workers yield,
178 // continuation information used by workers to continue the task
180 // immediately with no actual work having been done by the workers.
187 // Abort a currently running task, if any; returns when all the workers
192 // Yield: workers wait at their current working stations
196 // Abort: workers ar
[all...]
H A Dworkgroup.hpp124 // An abstract class representing a gang of workers.
135 // Stop and terminate all workers.
137 // Return true if more workers should be applied to the task.
151 // The count of the number of workers in the gang.
153 // Whether the workers should terminate.
162 // The number of started workers.
164 // The number of finished workers.
219 // Note activation and deactivation of workers.
258 WorkGang(const char* name, uint workers,
265 // Initialize workers i
332 FlexibleWorkGang(const char* name, uint workers, bool are_GC_task_threads, bool are_ConcurrentGC_threads) argument
[all...]
H A DyieldingWorkgroup.cpp36 const char* name, uint workers, bool are_GC_task_threads) :
37 FlexibleWorkGang(name, workers, are_GC_task_threads, false),
46 // Run a task; returns when the task is done, or the workers yield,
51 // continuation information used by workers to continue the task
53 // immediately with no actual work having been done by the workers.
58 Some subset of workers may have yielded and some may
60 been completed, the workers are bound to that task.
67 to the workers; the second is used to continue an
79 Set number of active workers (as asked)
80 Notify workers tha
35 YieldingFlexibleWorkGang( const char* name, uint workers, bool are_GC_task_threads) argument
[all...]
H A Dworkgroup.cpp56 uint workers,
60 _total_workers = workers;
71 // initialization of the workers and report such to the
110 stop(); // stop all the workers
121 assert(gang_workers() != NULL, "No workers for indexing");
141 // Tell all the workers to run a task.
148 // Tell the workers to get to work.
171 // must only be incremented for workers that find non_null
178 // Tell all workers to terminate, then wait for them to become inactive.
405 // 0, even after the notify_all(), given that some other workers
55 WorkGang(const char* name, uint workers, bool are_GC_task_threads, bool are_ConcurrentGC_threads) argument
[all...]
/openjdk7/hotspot/src/share/vm/memory/
H A DsharedHeap.hpp57 // must be set to the correct value so that count of workers that
66 // tasks is set to the number of GC workers, then _n_threads must
67 // be set to the number of active GC workers. G1CollectedHeap,
72 // number of active GC workers. CompactibleFreeListSpace and Space
89 // all_tasks_completed() to count the number of GC workers that have
90 // finished their work. That logic is "when all the workers are
252 FlexibleWorkGang* workers() const { return _workers; } function in class:SharedHeap
H A DcardTableModRefBS.cpp470 // of workers()->active_workers(). n_par_threads can be set to 0 to
476 // active gc workers. If parallelism has not been shut off by
499 SharedHeap::heap()->workers()->active_workers(), "Mismatch");
529 SharedHeap::heap()->workers()->active_workers()), "Mismatch");
H A DgenCollectedHeap.cpp1253 if (workers() != NULL) {
1254 workers()->threads_do(tc);
1266 workers()->print_worker_threads_on(st);
/openjdk7/hotspot/src/share/vm/gc_implementation/concurrentMarkSweep/
H A DconcurrentMarkSweepGeneration.cpp3784 int _n_workers; // requested/desired # workers
3809 YieldingFlexibleWorkGang* workers,
4202 // workers from interfering with the work done below.
4315 // Since the actual number of workers we get may be different
4361 // Get the workers going again
5123 // workers to be taken from the active workers in the work gang.
5127 int n_workers, FlexibleWorkGang* workers,
5372 // synchronization with other gang-workers while setting or
5420 // overflow list and does not affect the number of workers
[all...]

Completed in 157 milliseconds

12