hbase-common/src/main/java/org/apache/hadoop/hbase/util/HasThread.java

   1 /**
   2  * Licensed to the Apache Software Foundation (ASF) under one
   3  * or more contributor license agreements.  See the NOTICE file
   4  * distributed with this work for additional information
   5  * regarding copyright ownership.  The ASF licenses this file
   6  * to you under the Apache License, Version 2.0 (the
   7  * "License"); you may not use this file except in compliance
   8  * with the License.  You may obtain a copy of the License at
   9  *
  10  *     http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  */
  18 package org.apache.hadoop.hbase.util;
  19
  20 import java.lang.Thread.UncaughtExceptionHandler;
  21
  22 import org.apache.yetus.audience.InterfaceAudience;
  23
  24 /**
  25  * Abstract class which contains a Thread and delegates the common Thread
  26  * methods to that instance.
  27  *
  28  * The purpose of this class is to workaround Sun JVM bug #6915621, in which
  29  * something internal to the JDK uses Thread.currentThread() as a monitor
  30  * lock. This can produce deadlocks like HBASE-4367, HBASE-4101, etc.
  31  */
  32 @InterfaceAudience.Private
  33 public abstract class HasThread implements Runnable {
  34   private final Thread thread;
  35
  36   public HasThread() {
  37     this.thread = new Thread(this);
  38     this.thread.setDaemon(true);
  39   }
  40
  41   public HasThread(String name) {
  42     this.thread = new Thread(this, name);
  43     this.thread.setDaemon(true);
  44   }
  45
  46   public Thread getThread() {
  47     return thread;
  48   }
  49
  50   @Override
  51   public abstract void run();
  52
  53   //// Begin delegation to Thread
  54
  55   public final String getName() {
  56     return thread.getName();
  57   }
  58
  59   public void interrupt() {
  60     thread.interrupt();
  61   }
  62
  63   public final boolean isAlive() {
  64     return thread.isAlive();
  65   }
  66
  67   public boolean isInterrupted() {
  68     return thread.isInterrupted();
  69   }
  70
  71   public final void setDaemon(boolean on) {
  72     thread.setDaemon(on);
  73   }
  74
  75   public final void setName(String name) {
  76     thread.setName(name);
  77   }
  78
  79   public final void setPriority(int newPriority) {
  80     thread.setPriority(newPriority);
  81   }
  82
  83   public void setUncaughtExceptionHandler(UncaughtExceptionHandler eh) {
  84     thread.setUncaughtExceptionHandler(eh);
  85   }
  86
  87   public void start() {
  88     thread.start();
  89   }
  90
  91   public final void join() throws InterruptedException {
  92     thread.join();
  93   }
  94
  95   public final void join(long millis, int nanos) throws InterruptedException {
  96     thread.join(millis, nanos);
  97   }
  98
  99   public final void join(long millis) throws InterruptedException {
 100     thread.join(millis);
 101   }
 102   //// End delegation to Thread
 103 }