EZLippi/isolation-threadpool

IsolationCommandProperties.Builder builder1 = new IsolationCommandProperties.Builder()
                .withExecutionTimeoutEnabled(true)
                .withExecutionTimeoutInMilliseconds(1000)
                .withExecutionIsolationThreadInterruptOnTimeout(true);

IsolationThreadPoolProperties.Builder threadPoolBuilder1 = new IsolationThreadPoolProperties.Builder()
        .withCoreSize(1)
        .withMaximumSize(1)
        .withKeepAliveTimeMinutes(2)
        .withMaxQueueSize(10);

  IsolationCommand<String> command1 = new IsolationCommand<String>("command1", "pool1",
          builder1, threadPoolBuilder1, new DefaultExecutionHook()) {
      @Override
      protected String run() throws Exception {
          return "hello";
      }
  };
  IsolationCommand<String> command2 = new IsolationCommand<String>("command2", "pool2",
          builder1, threadPoolBuilder1, new DefaultExecutionHook()) {
      @Override
      protected String run() throws Exception {
          return "isolation";
      }
  };
  //将任务提交给线程池处理,queue()方法返回一个Future,调用者可以通过轮询或者阻塞获取返回值
  command1.queue();
  //调用线程同步获取返回值
  command2.execute();