hotspot/src/share/vm/runtime/task.cpp
author rbackman
Thu, 04 Oct 2012 14:55:57 +0200
changeset 14390 bd0d881cf1c5
parent 10565 dc90c239f4ec
child 14583 d70ee55535f4
permissions -rw-r--r--
7127792: Add the ability to change an existing PeriodicTask's execution interval Summary: Enables dynamic enrollment / disenrollment from the PeriodicTasks in WatcherThread. Reviewed-by: dholmes, mgronlun
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
     1
/*
7397
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
     2
 * Copyright (c) 1997, 2010, 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"
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    29
#include "runtime/timer.hpp"
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    30
#ifdef TARGET_OS_FAMILY_linux
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    31
# include "os_linux.inline.hpp"
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    32
# include "thread_linux.inline.hpp"
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    33
#endif
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    34
#ifdef TARGET_OS_FAMILY_solaris
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    35
# include "os_solaris.inline.hpp"
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    36
# include "thread_solaris.inline.hpp"
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    37
#endif
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    38
#ifdef TARGET_OS_FAMILY_windows
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    39
# include "os_windows.inline.hpp"
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    40
# include "thread_windows.inline.hpp"
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 5547
diff changeset
    41
#endif
10565
dc90c239f4ec 7089790: integrate bsd-port changes
never
parents: 7397
diff changeset
    42
#ifdef TARGET_OS_FAMILY_bsd
dc90c239f4ec 7089790: integrate bsd-port changes
never
parents: 7397
diff changeset
    43
# include "os_bsd.inline.hpp"
dc90c239f4ec 7089790: integrate bsd-port changes
never
parents: 7397
diff changeset
    44
# include "thread_bsd.inline.hpp"
dc90c239f4ec 7089790: integrate bsd-port changes
never
parents: 7397
diff changeset
    45
#endif
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
    46
489c9b5090e2 Initial load
duke
parents:
diff changeset
    47
int PeriodicTask::_num_tasks = 0;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    48
PeriodicTask* PeriodicTask::_tasks[PeriodicTask::max_tasks];
489c9b5090e2 Initial load
duke
parents:
diff changeset
    49
#ifndef PRODUCT
489c9b5090e2 Initial load
duke
parents:
diff changeset
    50
elapsedTimer PeriodicTask::_timer;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    51
int PeriodicTask::_intervalHistogram[PeriodicTask::max_interval];
489c9b5090e2 Initial load
duke
parents:
diff changeset
    52
int PeriodicTask::_ticks;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    53
489c9b5090e2 Initial load
duke
parents:
diff changeset
    54
void PeriodicTask::print_intervals() {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    55
  if (ProfilerCheckIntervals) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    56
    for (int i = 0; i < PeriodicTask::max_interval; i++) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    57
      int n = _intervalHistogram[i];
489c9b5090e2 Initial load
duke
parents:
diff changeset
    58
      if (n > 0) tty->print_cr("%3d: %5d (%4.1f%%)", i, n, 100.0 * n / _ticks);
489c9b5090e2 Initial load
duke
parents:
diff changeset
    59
    }
489c9b5090e2 Initial load
duke
parents:
diff changeset
    60
  }
489c9b5090e2 Initial load
duke
parents:
diff changeset
    61
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
    62
#endif
489c9b5090e2 Initial load
duke
parents:
diff changeset
    63
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    64
void PeriodicTask::real_time_tick(int delay_time) {
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
    65
#ifndef PRODUCT
489c9b5090e2 Initial load
duke
parents:
diff changeset
    66
  if (ProfilerCheckIntervals) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    67
    _ticks++;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    68
    _timer.stop();
489c9b5090e2 Initial load
duke
parents:
diff changeset
    69
    int ms = (int)(_timer.seconds() * 1000.0);
489c9b5090e2 Initial load
duke
parents:
diff changeset
    70
    _timer.reset();
489c9b5090e2 Initial load
duke
parents:
diff changeset
    71
    _timer.start();
489c9b5090e2 Initial load
duke
parents:
diff changeset
    72
    if (ms >= PeriodicTask::max_interval) ms = PeriodicTask::max_interval - 1;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    73
    _intervalHistogram[ms]++;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    74
  }
489c9b5090e2 Initial load
duke
parents:
diff changeset
    75
#endif
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    76
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    77
  {
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    78
    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
    79
    int orig_num_tasks = _num_tasks;
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    80
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    81
    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
    82
      _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
    83
      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
    84
        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
    85
        orig_num_tasks = _num_tasks;
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    86
      }
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
    87
    }
489c9b5090e2 Initial load
duke
parents:
diff changeset
    88
  }
489c9b5090e2 Initial load
duke
parents:
diff changeset
    89
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
    90
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    91
int PeriodicTask::time_to_wait() {
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    92
  MutexLockerEx ml(PeriodicTask_lock->owned_by_self() ?
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    93
                     NULL : 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
    94
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    95
  if (_num_tasks == 0) {
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    96
    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
    97
  }
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    98
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
    99
  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
   100
  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
   101
    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
   102
  }
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   103
  return delay;
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   104
}
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   105
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   106
489c9b5090e2 Initial load
duke
parents:
diff changeset
   107
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
   108
  _counter(0), _interval((int) interval_time) {
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   109
  // Sanity check the interval time
489c9b5090e2 Initial load
duke
parents:
diff changeset
   110
  assert(_interval >= PeriodicTask::min_interval &&
489c9b5090e2 Initial load
duke
parents:
diff changeset
   111
         _interval <= PeriodicTask::max_interval &&
489c9b5090e2 Initial load
duke
parents:
diff changeset
   112
         _interval %  PeriodicTask::interval_gran == 0,
489c9b5090e2 Initial load
duke
parents:
diff changeset
   113
              "improper PeriodicTask interval time");
489c9b5090e2 Initial load
duke
parents:
diff changeset
   114
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   115
489c9b5090e2 Initial load
duke
parents:
diff changeset
   116
PeriodicTask::~PeriodicTask() {
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   117
  disenroll();
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   118
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   119
489c9b5090e2 Initial load
duke
parents:
diff changeset
   120
void PeriodicTask::enroll() {
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   121
  MutexLockerEx ml(PeriodicTask_lock->owned_by_self() ?
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   122
                     NULL : PeriodicTask_lock, Mutex::_no_safepoint_check_flag);
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   123
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   124
  if (_num_tasks == PeriodicTask::max_tasks) {
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   125
    fatal("Overflow in PeriodicTask table");
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   126
  }
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   127
  _tasks[_num_tasks++] = this;
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   128
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   129
  WatcherThread* thread = WatcherThread::watcher_thread();
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   130
  if (thread) {
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   131
    thread->unpark();
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   132
  } else {
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   133
    WatcherThread::start();
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   134
  }
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
   135
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   136
489c9b5090e2 Initial load
duke
parents:
diff changeset
   137
void PeriodicTask::disenroll() {
14390
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   138
  MutexLockerEx ml(PeriodicTask_lock->owned_by_self() ?
bd0d881cf1c5 7127792: Add the ability to change an existing PeriodicTask's execution interval
rbackman
parents: 10565
diff changeset
   139
                     NULL : PeriodicTask_lock, Mutex::_no_safepoint_check_flag);
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
}