hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/StoppableThread.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.procedure2;
  19
  20 import org.apache.hadoop.hbase.procedure2.util.StringUtils;
  21 import org.apache.hadoop.hbase.util.EnvironmentEdgeManager;
  22 import org.apache.yetus.audience.InterfaceAudience;
  23 import org.slf4j.Logger;
  24 import org.slf4j.LoggerFactory;
  25
  26 @InterfaceAudience.Private
  27 abstract class StoppableThread extends Thread {
  28
  29   private static final Logger LOG = LoggerFactory.getLogger(StoppableThread.class);
  30
  31   public StoppableThread(final ThreadGroup group, final String name) {
  32     super(group, name);
  33   }
  34
  35   public abstract void sendStopSignal();
  36
  37   public void awaitTermination() {
  38     try {
  39       final long startTime = EnvironmentEdgeManager.currentTime();
  40       for (int i = 0; isAlive(); ++i) {
  41         sendStopSignal();
  42         join(250);
  43         // Log every two seconds; send interrupt too.
  44         if (i > 0 && (i % 8) == 0) {
  45           LOG.warn("Waiting termination of thread {}, {}; sending interrupt", getName(),
  46             StringUtils.humanTimeDiff(EnvironmentEdgeManager.currentTime() - startTime));
  47           interrupt();
  48         }
  49       }
  50     } catch (InterruptedException e) {
  51       LOG.warn("{} join wait got interrupted", getName(), e);
  52     }
  53   }
  54 }