author | mgerdin |
Wed, 04 May 2016 10:06:00 +0200 | |
changeset 38184 | c149a974c35b |
parent 37081 | 7656f5356a5d |
child 39452 | eebe070746ad |
permissions | -rw-r--r-- |
23472 | 1 |
/* |
37081
7656f5356a5d
8140257: Add support for "gc service threads" to ConcurrentGCThread
drwhite
parents:
35061
diff
changeset
|
2 |
* Copyright (c) 2014, 2016, Oracle and/or its affiliates. All rights reserved. |
23472 | 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 |
* |
|
23 |
*/ |
|
24 |
||
25 |
#include "precompiled.hpp" |
|
31345
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
26 |
#include "classfile/stringTable.hpp" |
30764 | 27 |
#include "gc/g1/g1StringDedup.hpp" |
28 |
#include "gc/g1/g1StringDedupQueue.hpp" |
|
29 |
#include "gc/g1/g1StringDedupTable.hpp" |
|
30 |
#include "gc/g1/g1StringDedupThread.hpp" |
|
30770
5ba2d9f2084d
8080585: concurrentGCThread.hpp should not include suspendibleThreadSet.hpp
pliden
parents:
30764
diff
changeset
|
31 |
#include "gc/g1/suspendibleThreadSet.hpp" |
35061 | 32 |
#include "logging/log.hpp" |
31345
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
33 |
#include "oops/oop.inline.hpp" |
25351
7c198a690050
8044775: Improve usage of umbrella header atomic.inline.hpp.
goetz
parents:
24331
diff
changeset
|
34 |
#include "runtime/atomic.inline.hpp" |
23472 | 35 |
|
36 |
G1StringDedupThread* G1StringDedupThread::_thread = NULL; |
|
37 |
||
38 |
G1StringDedupThread::G1StringDedupThread() : |
|
39 |
ConcurrentGCThread() { |
|
29464
02c245ad3ec9
8073545: Use shorter and more descriptive names for GC worker threads
david
parents:
25351
diff
changeset
|
40 |
set_name("G1 StrDedup"); |
23472 | 41 |
create_and_start(); |
42 |
} |
|
43 |
||
44 |
G1StringDedupThread::~G1StringDedupThread() { |
|
45 |
ShouldNotReachHere(); |
|
46 |
} |
|
47 |
||
48 |
void G1StringDedupThread::create() { |
|
49 |
assert(G1StringDedup::is_enabled(), "String deduplication not enabled"); |
|
50 |
assert(_thread == NULL, "One string deduplication thread allowed"); |
|
51 |
_thread = new G1StringDedupThread(); |
|
52 |
} |
|
53 |
||
54 |
G1StringDedupThread* G1StringDedupThread::thread() { |
|
55 |
assert(G1StringDedup::is_enabled(), "String deduplication not enabled"); |
|
56 |
assert(_thread != NULL, "String deduplication thread not created"); |
|
57 |
return _thread; |
|
58 |
} |
|
59 |
||
31345
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
60 |
class G1StringDedupSharedClosure: public OopClosure { |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
61 |
private: |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
62 |
G1StringDedupStat& _stat; |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
63 |
|
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
64 |
public: |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
65 |
G1StringDedupSharedClosure(G1StringDedupStat& stat) : _stat(stat) {} |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
66 |
|
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
67 |
virtual void do_oop(oop* p) { ShouldNotReachHere(); } |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
68 |
virtual void do_oop(narrowOop* p) { |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
69 |
oop java_string = oopDesc::load_decode_heap_oop(p); |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
70 |
G1StringDedupTable::deduplicate(java_string, _stat); |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
71 |
} |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
72 |
}; |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
73 |
|
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
74 |
// The CDS archive does not include the string dedupication table. Only the string |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
75 |
// table is saved in the archive. The shared strings from CDS archive need to be |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
76 |
// added to the string dedupication table before deduplication occurs. That is |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
77 |
// done in the begining of the G1StringDedupThread (see G1StringDedupThread::run() |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
78 |
// below). |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
79 |
void G1StringDedupThread::deduplicate_shared_strings(G1StringDedupStat& stat) { |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
80 |
G1StringDedupSharedClosure sharedStringDedup(stat); |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
81 |
StringTable::shared_oops_do(&sharedStringDedup); |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
82 |
} |
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
83 |
|
37081
7656f5356a5d
8140257: Add support for "gc service threads" to ConcurrentGCThread
drwhite
parents:
35061
diff
changeset
|
84 |
void G1StringDedupThread::run_service() { |
23472 | 85 |
G1StringDedupStat total_stat; |
86 |
||
31345
1bba15125d8d
8015086: add interned strings to the shared archive.
jiangli
parents:
30770
diff
changeset
|
87 |
deduplicate_shared_strings(total_stat); |
23472 | 88 |
|
89 |
// Main loop |
|
90 |
for (;;) { |
|
91 |
G1StringDedupStat stat; |
|
92 |
||
93 |
stat.mark_idle(); |
|
94 |
||
95 |
// Wait for the queue to become non-empty |
|
96 |
G1StringDedupQueue::wait(); |
|
37081
7656f5356a5d
8140257: Add support for "gc service threads" to ConcurrentGCThread
drwhite
parents:
35061
diff
changeset
|
97 |
if (should_terminate()) { |
24093
095cc0a63ed9
8037112: gc/g1/TestHumongousAllocInitialMark.java caused SIGSEGV
pliden
parents:
23472
diff
changeset
|
98 |
break; |
095cc0a63ed9
8037112: gc/g1/TestHumongousAllocInitialMark.java caused SIGSEGV
pliden
parents:
23472
diff
changeset
|
99 |
} |
23472 | 100 |
|
24094 | 101 |
{ |
102 |
// Include thread in safepoints |
|
30613
a7815bb05ae2
8079579: Add SuspendibleThreadSetLeaver and make SuspendibleThreadSet::joint()/leave() private
pliden
parents:
29464
diff
changeset
|
103 |
SuspendibleThreadSetJoiner sts_join; |
23472 | 104 |
|
24094 | 105 |
stat.mark_exec(); |
23472 | 106 |
|
24094 | 107 |
// Process the queue |
108 |
for (;;) { |
|
109 |
oop java_string = G1StringDedupQueue::pop(); |
|
110 |
if (java_string == NULL) { |
|
111 |
break; |
|
112 |
} |
|
113 |
||
114 |
G1StringDedupTable::deduplicate(java_string, stat); |
|
115 |
||
116 |
// Safepoint this thread if needed |
|
30613
a7815bb05ae2
8079579: Add SuspendibleThreadSetLeaver and make SuspendibleThreadSet::joint()/leave() private
pliden
parents:
29464
diff
changeset
|
117 |
if (sts_join.should_yield()) { |
24094 | 118 |
stat.mark_block(); |
30613
a7815bb05ae2
8079579: Add SuspendibleThreadSetLeaver and make SuspendibleThreadSet::joint()/leave() private
pliden
parents:
29464
diff
changeset
|
119 |
sts_join.yield(); |
24094 | 120 |
stat.mark_unblock(); |
121 |
} |
|
23472 | 122 |
} |
123 |
||
24094 | 124 |
G1StringDedupTable::trim_entry_cache(); |
23472 | 125 |
|
24094 | 126 |
stat.mark_done(); |
23472 | 127 |
|
24094 | 128 |
// Print statistics |
129 |
total_stat.add(stat); |
|
35061 | 130 |
print(stat, total_stat); |
24094 | 131 |
} |
23472 | 132 |
} |
133 |
||
24093
095cc0a63ed9
8037112: gc/g1/TestHumongousAllocInitialMark.java caused SIGSEGV
pliden
parents:
23472
diff
changeset
|
134 |
} |
095cc0a63ed9
8037112: gc/g1/TestHumongousAllocInitialMark.java caused SIGSEGV
pliden
parents:
23472
diff
changeset
|
135 |
|
37081
7656f5356a5d
8140257: Add support for "gc service threads" to ConcurrentGCThread
drwhite
parents:
35061
diff
changeset
|
136 |
void G1StringDedupThread::stop_service() { |
24093
095cc0a63ed9
8037112: gc/g1/TestHumongousAllocInitialMark.java caused SIGSEGV
pliden
parents:
23472
diff
changeset
|
137 |
G1StringDedupQueue::cancel_wait(); |
23472 | 138 |
} |
139 |
||
35061 | 140 |
void G1StringDedupThread::print(const G1StringDedupStat& last_stat, const G1StringDedupStat& total_stat) { |
141 |
if (log_is_enabled(Info, gc, stringdedup)) { |
|
142 |
G1StringDedupStat::print_summary(last_stat, total_stat); |
|
143 |
if (log_is_enabled(Debug, gc, stringdedup)) { |
|
144 |
G1StringDedupStat::print_statistics(last_stat, false); |
|
145 |
G1StringDedupStat::print_statistics(total_stat, true); |
|
146 |
G1StringDedupTable::print_statistics(); |
|
147 |
G1StringDedupQueue::print_statistics(); |
|
23472 | 148 |
} |
149 |
} |
|
150 |
} |