1 /*
   2  * Copyright (c) 2018, 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  *
  23  */
  24 
  25 #ifndef SHARE_VM_GC_SHARED_STRINGDEDUP_STRINGDEDUPTHREAD_INLINE_HPP
  26 #define SHARE_VM_GC_SHARED_STRINGDEDUP_STRINGDEDUPTHREAD_INLINE_HPP
  27 
  28 #include "gc/shared/suspendibleThreadSet.hpp"
  29 #include "gc/shared/stringdedup/stringDedupQueue.inline.hpp"
  30 #include "gc/shared/stringdedup/stringDedupThread.hpp"
  31 
  32 template <typename STAT>
  33 void StringDedupThreadImpl<STAT>::do_deduplication() {
  34   STAT total_stat;
  35 
  36   deduplicate_shared_strings(&total_stat);
  37 
  38   // Main loop
  39   for (;;) {
  40     STAT stat;
  41 
  42     stat.mark_idle();
  43 
  44     // Wait for the queue to become non-empty
  45     StringDedupQueue::wait();
  46     if (this->should_terminate()) {
  47       break;
  48     }
  49 
  50     {
  51       // Include thread in safepoints
  52       SuspendibleThreadSetJoiner sts_join;
  53 
  54       stat.mark_exec();
  55       StringDedupStat::print_start(&stat);
  56 
  57       // Process the queue
  58       for (;;) {
  59         oop java_string = StringDedupQueue::pop();
  60         if (java_string == NULL) {
  61           break;
  62         }
  63 
  64         StringDedupTable::deduplicate(java_string, &stat);
  65 
  66         // Safepoint this thread if needed
  67         if (sts_join.should_yield()) {
  68           stat.mark_block();
  69           sts_join.yield();
  70           stat.mark_unblock();
  71         }
  72       }
  73 
  74       stat.mark_done();
  75 
  76       total_stat.add(&stat);
  77       print_end(&stat, &total_stat);
  78       stat.reset();
  79     }
  80 
  81     StringDedupTable::clean_entry_cache();
  82   }
  83 }
  84 
  85 template <typename STAT>
  86 void StringDedupThreadImpl<STAT>::create() {
  87   assert(_thread == NULL, "One string deduplication thread allowed");
  88   _thread = new StringDedupThreadImpl<STAT>();
  89 }
  90 
  91 #endif // SHARE_VM_GC_SHARED_STRINGDEDUP_STRINGDEDUPTHREAD_INLINE_HPP