@Test public void testShutdownGetsNewThreadPool() throws Exception{ Map<String, Object> cache = new HashMap<String, Object>(); ThreadPoolBuilder builder = new ThreadPoolBuilder(name.getTableNameString(), new Configuration(false)); ThreadPoolExecutor exec = ThreadPoolManager.getExecutor(builder, cache); assertNotNull("Got a null exector from the pool!", exec); exec.shutdown(); ThreadPoolExecutor exec2 = ThreadPoolManager.getExecutor(builder, cache); assertFalse("Got the same exectuor, even though the original shutdown", exec2 == exec); }
public static synchronized ThreadPoolExecutor getExecutor(ThreadPoolBuilder builder, RegionCoprocessorEnvironment env) { return getExecutor(builder, env.getSharedData()); }
ThreadPoolManager { public static synchronized ThreadPoolExecutor getExecutor(ThreadPoolBuilder builder, RegionCoprocessorEnvironment env) { return getExecutor(builder, env.getSharedData()); } }
ThreadPoolManager { public static synchronized ThreadPoolExecutor getExecutor(ThreadPoolBuilder builder, RegionCoprocessorEnvironment env) { return getExecutor(builder, env.getSharedData()); }  }
ThreadPoolManager { public static synchronized ThreadPoolExecutor getExecutor(ThreadPoolBuilder builder, RegionCoprocessorEnvironment env) { return getExecutor(builder, env.getSharedData()); }  static synchronized ThreadPoolExecutor getExecutor(ThreadPoolBuilder builder,
      RegionCoprocessorEnvironment env); }
ThreadPoolManager { public static synchronized ThreadPoolExecutor getExecutor(ThreadPoolBuilder builder, RegionCoprocessorEnvironment env) { return getExecutor(builder, env.getSharedData()); }  static synchronized ThreadPoolExecutor getExecutor(ThreadPoolBuilder builder,
      RegionCoprocessorEnvironment env);  }