1 /*
2 * Copyright (c) 2001, 2019, Oracle and/or its affiliates. All rights reserved.
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4 *
5 * This code is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License version 2 only, as
7 * published by the Free Software Foundation.
8 *
9 * This code is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
12 * version 2 for more details (a copy is included in the LICENSE file that
13 * accompanied this code).
14 *
15 * You should have received a copy of the GNU General Public License version
16 * 2 along with this work; if not, write to the Free Software Foundation,
17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18 *
19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20 * or visit www.oracle.com if you need additional information or have any
21 * questions.
22 *
28 #include "gc/shared/concurrentGCThread.hpp"
29 #include "utilities/ticks.hpp"
30
31 // Forward Decl.
32 class G1ConcurrentRefine;
33
34 // One or more G1 Concurrent Refinement Threads may be active if concurrent
35 // refinement is in progress.
36 class G1ConcurrentRefineThread: public ConcurrentGCThread {
37 friend class VMStructs;
38 friend class G1CollectedHeap;
39
40 double _vtime_start; // Initial virtual time.
41 double _vtime_accum; // Accumulated virtual time.
42
43 Tickspan _total_refinement_time;
44 size_t _total_refined_cards;
45
46 uint _worker_id;
47
48 bool _active;
49 Monitor* _monitor;
50 G1ConcurrentRefine* _cr;
51
52 void wait_for_completed_buffers();
53
54 void set_active(bool x) { _active = x; }
55 // Deactivate this thread.
56 void deactivate();
57
58 bool is_primary() { return (_worker_id == 0); }
59
60 void run_service();
61 void stop_service();
62 public:
63 G1ConcurrentRefineThread(G1ConcurrentRefine* cg1r, uint worker_id);
64
65 bool is_active();
66 // Activate this thread.
67 void activate();
68
69 Tickspan total_refinement_time() const { return _total_refinement_time; }
70 size_t total_refined_cards() const { return _total_refined_cards; }
71
72 // Total virtual time so far.
73 double vtime_accum() { return _vtime_accum; }
74 };
75
76 #endif // SHARE_GC_G1_G1CONCURRENTREFINETHREAD_HPP
|
1 /*
2 * Copyright (c) 2001, 2020, Oracle and/or its affiliates. All rights reserved.
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4 *
5 * This code is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License version 2 only, as
7 * published by the Free Software Foundation.
8 *
9 * This code is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
12 * version 2 for more details (a copy is included in the LICENSE file that
13 * accompanied this code).
14 *
15 * You should have received a copy of the GNU General Public License version
16 * 2 along with this work; if not, write to the Free Software Foundation,
17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18 *
19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20 * or visit www.oracle.com if you need additional information or have any
21 * questions.
22 *
28 #include "gc/shared/concurrentGCThread.hpp"
29 #include "utilities/ticks.hpp"
30
31 // Forward Decl.
32 class G1ConcurrentRefine;
33
34 // One or more G1 Concurrent Refinement Threads may be active if concurrent
35 // refinement is in progress.
36 class G1ConcurrentRefineThread: public ConcurrentGCThread {
37 friend class VMStructs;
38 friend class G1CollectedHeap;
39
40 double _vtime_start; // Initial virtual time.
41 double _vtime_accum; // Accumulated virtual time.
42
43 Tickspan _total_refinement_time;
44 size_t _total_refined_cards;
45
46 uint _worker_id;
47
48 // Each thread has its own semaphore. The i-th thread is responsible for
49 // signaling thread i+1 if the number of buffers in the queue exceeds a
50 // threshold for that thread. Semaphores are also used to wake up the
51 // threads during termination. The 0th (primary) worker is notified by
52 // mutator threads.
53 Semaphore* _notifier;
54 volatile bool _should_notify;
55 bool maybe_deactivate(bool more_work);
56
57 G1ConcurrentRefine* _cr;
58
59 void wait_for_completed_buffers();
60
61 virtual void run_service();
62 virtual void stop_service();
63
64 public:
65 G1ConcurrentRefineThread(G1ConcurrentRefine* cg1r, uint worker_id);
66
67 // Activate this thread.
68 void activate();
69
70 Tickspan total_refinement_time() const { return _total_refinement_time; }
71 size_t total_refined_cards() const { return _total_refined_cards; }
72
73 // Total virtual time so far.
74 double vtime_accum() { return _vtime_accum; }
75 };
76
77 #endif // SHARE_GC_G1_G1CONCURRENTREFINETHREAD_HPP
|