src/hotspot/share/runtime/task.cpp
author erikj
Tue, 12 Sep 2017 19:03:39 +0200
changeset 47216 71c04702a3d5
parent 33794 hotspot/src/share/vm/runtime/task.cpp@41ef3dc95179
child 53750 2cf90fac6e39
permissions -rw-r--r--
8187443: Forest Consolidation: Move files to unified layout Reviewed-by: darcy, ihse
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
     1
/*
29321
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
     2
 * Copyright (c) 1997, 2015, Oracle and/or its affiliates. All rights reserved.
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
     3
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
489c9b5090e2 Initial load
duke
parents:
diff changeset
     4
 *
489c9b5090e2 Initial load
duke
parents:
diff changeset
     5
 * This code is free software; you can redistribute it and/or modify it
489c9b5090e2 Initial load
duke
parents:
diff changeset
     6
 * under the terms of the GNU General Public License version 2 only, as
489c9b5090e2 Initial load
duke
parents:
diff changeset
     7
 * published by the Free Software Foundation.
489c9b5090e2 Initial load
duke
parents:
diff changeset
     8
 *
489c9b5090e2 Initial load
duke
parents:
diff changeset
     9
 * This code is distributed in the hope that it will be useful, but WITHOUT
489c9b5090e2 Initial load
duke
parents:
diff changeset
    10
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
489c9b5090e2 Initial load
duke
parents:
diff changeset
    11
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
489c9b5090e2 Initial load
duke
parents:
diff changeset
    12
 * version 2 for more details (a copy is included in the LICENSE file that
489c9b5090e2 Initial load
duke
parents:
diff changeset
    13
 * accompanied this code).
489c9b5090e2 Initial load
duke
parents:
diff changeset
    14
 *
489c9b5090e2 Initial load
duke
parents:
diff changeset
    15
 * You should have received a copy of the GNU General Public License version
489c9b5090e2 Initial load
duke
parents:
diff changeset
    16
 * 2 along with this work; if not, write to the Free Software Foundation,
489c9b5090e2 Initial load
duke
parents:
diff changeset
    17
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
489c9b5090e2 Initial load
duke
parents:
diff changeset
    18
 *
5547
f4b087cbb361 6941466: Oracle rebranding changes for Hotspot repositories
trims
parents: 1388
diff changeset
    19
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
f4b087cbb361 6941466: Oracle rebranding changes for Hotspot repositories
trims
parents: 1388
diff changeset
    20
 * or visit www.oracle.com if you need additional information or have any
f4b087cbb361 6941466: Oracle rebranding changes for Hotspot repositories
trims
parents: 1388
diff changeset
    21
 * questions.
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
    22
 *
489c9b5090e2 Initial load
duke
parents:
diff changeset
    23
 */
489c9b5090e2 Initial load
duke
parents:
diff changeset
    24
7397
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    25
#include "precompiled.hpp"
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    26
#include "memory/allocation.hpp"
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    27
#include "runtime/init.hpp"
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    28
#include "runtime/task.hpp"
14583
d70ee55535f4 8003935: Simplify the needed includes for using Thread::current()
stefank
parents: 14390
diff changeset
    29
#include "runtime/thread.inline.hpp"
7397
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    30
#include "runtime/timer.hpp"
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
    31
489c9b5090e2 Initial load
duke
parents:
diff changeset
    32
int PeriodicTask::_num_tasks = 0;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    33
PeriodicTask* PeriodicTask::_tasks[PeriodicTask::max_tasks];
489c9b5090e2 Initial load
duke
parents:
diff changeset
    34
#ifndef PRODUCT
489c9b5090e2 Initial load
duke
parents:
diff changeset
    35
elapsedTimer PeriodicTask::_timer;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    36
int PeriodicTask::_intervalHistogram[PeriodicTask::max_interval];
489c9b5090e2 Initial load
duke
parents:
diff changeset
    37
int PeriodicTask::_ticks;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    38
489c9b5090e2 Initial load
duke
parents:
diff changeset
    39
void PeriodicTask::print_intervals() {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    40
  if (ProfilerCheckIntervals) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    41
    for (int i = 0; i < PeriodicTask::max_interval; i++) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    42
      int n = _intervalHistogram[i];
489c9b5090e2 Initial load
duke
parents:
diff changeset
    43
      if (n > 0) tty->print_cr("%3d: %5d (%4.1f%%)", i, n, 100.0 * n / _ticks);
489c9b5090e2 Initial load
duke
parents:
diff changeset
    44
    }
489c9b5090e2 Initial load
duke
parents:
diff changeset
    45
  }
489c9b5090e2 Initial load
duke
parents:
diff changeset
    46
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
    47
#endif
489c9b5090e2 Initial load
duke
parents:
diff changeset
    48
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    49
void PeriodicTask::real_time_tick(int delay_time) {
29321
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
    50
  assert(Thread::current()->is_Watcher_thread(), "must be WatcherThread");
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
    51
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
    52
#ifndef PRODUCT
489c9b5090e2 Initial load
duke
parents:
diff changeset
    53
  if (ProfilerCheckIntervals) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    54
    _ticks++;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    55
    _timer.stop();
30608
d79880a5cf2f 8079561: Add a method to convert counters to milliseconds
brutisso
parents: 29321
diff changeset
    56
    int ms = (int)_timer.milliseconds();
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
    57
    _timer.reset();
489c9b5090e2 Initial load
duke
parents:
diff changeset
    58
    _timer.start();
489c9b5090e2 Initial load
duke
parents:
diff changeset
    59
    if (ms >= PeriodicTask::max_interval) ms = PeriodicTask::max_interval - 1;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    60
    _intervalHistogram[ms]++;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    61
  }
489c9b5090e2 Initial load
duke
parents:
diff changeset
    62
#endif
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    63
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    64
  {
29321
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
    65
    // The WatcherThread does not participate in the safepoint protocol
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
    66
    // for the PeriodicTask_lock because it is not a JavaThread.
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    67
    MutexLockerEx ml(PeriodicTask_lock, Mutex::_no_safepoint_check_flag);
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    68
    int orig_num_tasks = _num_tasks;
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    69
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    70
    for(int index = 0; index < _num_tasks; index++) {
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    71
      _tasks[index]->execute_if_pending(delay_time);
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    72
      if (_num_tasks < orig_num_tasks) { // task dis-enrolled itself
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    73
        index--;  // re-do current slot as it has changed
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    74
        orig_num_tasks = _num_tasks;
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    75
      }
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
    76
    }
489c9b5090e2 Initial load
duke
parents:
diff changeset
    77
  }
489c9b5090e2 Initial load
duke
parents:
diff changeset
    78
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
    79
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    80
int PeriodicTask::time_to_wait() {
29321
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
    81
  assert(PeriodicTask_lock->owned_by_self(), "PeriodicTask_lock required");
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    82
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    83
  if (_num_tasks == 0) {
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    84
    return 0; // sleep until shutdown or a task is enrolled
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    85
  }
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    86
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    87
  int delay = _tasks[0]->time_to_next_interval();
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    88
  for (int index = 1; index < _num_tasks; index++) {
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    89
    delay = MIN2(delay, _tasks[index]->time_to_next_interval());
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    90
  }
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    91
  return delay;
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    92
}
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    93
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
    94
489c9b5090e2 Initial load
duke
parents:
diff changeset
    95
PeriodicTask::PeriodicTask(size_t interval_time) :
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    96
  _counter(0), _interval((int) interval_time) {
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
    97
  // Sanity check the interval time
489c9b5090e2 Initial load
duke
parents:
diff changeset
    98
  assert(_interval >= PeriodicTask::min_interval &&
489c9b5090e2 Initial load
duke
parents:
diff changeset
    99
         _interval %  PeriodicTask::interval_gran == 0,
489c9b5090e2 Initial load
duke
parents:
diff changeset
   100
              "improper PeriodicTask interval time");
489c9b5090e2 Initial load
duke
parents:
diff changeset
   101
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   102
489c9b5090e2 Initial load
duke
parents:
diff changeset
   103
PeriodicTask::~PeriodicTask() {
29321
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   104
  // This PeriodicTask may have already been disenrolled by a call
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   105
  // to disenroll() before the PeriodicTask was deleted.
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   106
  disenroll();
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   107
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   108
29321
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   109
// enroll the current PeriodicTask
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   110
void PeriodicTask::enroll() {
29321
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   111
  // Follow normal safepoint aware lock enter protocol if the caller does
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   112
  // not already own the PeriodicTask_lock. Otherwise, we don't try to
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   113
  // enter it again because VM internal Mutexes do not support recursion.
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   114
  //
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   115
  MutexLockerEx ml(PeriodicTask_lock->owned_by_self() ? NULL
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   116
                                                      : PeriodicTask_lock);
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   117
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   118
  if (_num_tasks == PeriodicTask::max_tasks) {
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   119
    fatal("Overflow in PeriodicTask table");
33794
41ef3dc95179 8140482: Various minor code improvements (runtime)
goetz
parents: 30608
diff changeset
   120
  } else {
41ef3dc95179 8140482: Various minor code improvements (runtime)
goetz
parents: 30608
diff changeset
   121
    _tasks[_num_tasks++] = this;
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   122
  }
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   123
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   124
  WatcherThread* thread = WatcherThread::watcher_thread();
29321
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   125
  if (thread != NULL) {
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   126
    thread->unpark();
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   127
  } else {
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   128
    WatcherThread::start();
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   129
  }
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   130
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   131
29321
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   132
// disenroll the current PeriodicTask
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   133
void PeriodicTask::disenroll() {
29321
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   134
  // Follow normal safepoint aware lock enter protocol if the caller does
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   135
  // not already own the PeriodicTask_lock. Otherwise, we don't try to
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   136
  // enter it again because VM internal Mutexes do not support recursion.
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   137
  //
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   138
  MutexLockerEx ml(PeriodicTask_lock->owned_by_self() ? NULL
b7582a690cb9 8072439: fix for 8047720 may need more work
dcubed
parents: 25468
diff changeset
   139
                                                      : PeriodicTask_lock);
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   140
489c9b5090e2 Initial load
duke
parents:
diff changeset
   141
  int index;
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   142
  for(index = 0; index < _num_tasks && _tasks[index] != this; index++)
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   143
    ;
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   144
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   145
  if (index == _num_tasks) {
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   146
    return;
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   147
  }
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   148
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   149
  _num_tasks--;
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   150
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   151
  for (; index < _num_tasks; index++) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
   152
    _tasks[index] = _tasks[index+1];
489c9b5090e2 Initial load
duke
parents:
diff changeset
   153
  }
489c9b5090e2 Initial load
duke
parents:
diff changeset
   154
}