使用 java.util.concurrent API 结束线程

Question

我正在使用线程，并决定使用最现代的 API（java.util.concurrent 包）。

这是我想要做的（伪代码）：

//List of threads

private ScheduledExecutorService checkIns = Executors.newScheduledThreadPool(10);
//Runnable class

private class TestThread implements Runnable{
  private int index = 0;
  private long startTime = 0;
  private long timeToExecute = 3000000;
   public TestThread(int index){
      this.index = index;
   }

   public void run(){
      if(startTime == 0)
        startTime = System.currentTimeMillis();
      else if(startTime > (startTime+timeToExecute))
           //End Thread
      System.out.println("Execute thread with index->"+index);
    }
}

//Cycle to create 3 threads
for(int i=0;i< 3; i++)
    checkIns.scheduleWithFixedDelay(new TestThread(i+1),1, 3, TimeUnit.SECONDS);

我想在某个日期运行一个任务并重复它直到一定的时间。时间过去后，任务结束。我唯一的问题是如何结束线程？

Answer 1

好吧，当任务不再执行时，您可以抛出异常，但这是相当残酷的替代方案：

• 将任务调度一次，使任务了解调度程序，以便它可以在需要时重新调度自己完成当前迭代 - 但如果在最后时间之后，则立即返回。
• 使用像 Quartz Scheduler 这样的东西，它更适合此类事情。

当然，第一个版本可以封装成更令人愉快的形式 - 您可以创建一个“SchedulingRunnable”，它知道何时运行子任务（提供给它）以及运行多长时间。

Answer 2

当线程的 run 方法存在时，该线程终止。似乎您只需要执行以下操作：

public void run(){
  if(startTime == 0)
    startTime = System.currentTimeMillis();

  while (System.currentTimeMillis() < (startTime+timeToExecute)){
       // do work here
  }

  //End Thread
  System.out.println("Execute thread with index->"+index);
}

Answer 3

如果你想做一个连续的任务：在 run 函数中创建一个 while 循环，时不时地检查它是否运行了足够长的时间。当任务完成时（run() 函数退出），线程可以自由地用于其他任务。使用调度程序将任务安排为每天重复。

如果您不想要连续的任务，您有多种选择。我想说的最简单的方法是，如果您想安排一项新的一次性任务，则决定何时完成部分任务。