无论上一个任务是否结束，我都想每隔 1 秒定期启动一个任务

Question

无论之前的任务是否结束，我都想每隔 1 秒定期运行一次任务。我尝试了下面的代码，但它没有工作它正在等待 完成上一个任务然后开始另一个任务。

public static void main(String[] args) throws Exception {
     ScheduledExecutorService scheduledPool = Executors.newScheduledThreadPool(5);
     scheduledPool.scheduleAtFixedRate(new Runnable(){
                 public void run(){
                     System.out.println(Thread.currentThread().getName() + "startTime : "+ new Date());
                    sleepForNSeconds(5);
                     System.out.println(Thread.currentThread().getName()  +"endTime : "+ new Date());
                 }
                 }, 0,1, TimeUnit.SECONDS);

 }

输出：

pool-1-thread-1startTime : Wed Jul 06 21:04:15 IST 2016
pool-1-thread-1endTime : Wed Jul 06 21:04:21 IST 2016
pool-1-thread-1startTime : Wed Jul 06 21:04:21 IST 2016
pool-1-thread-1endTime : Wed Jul 06 21:04:26 IST 2016
pool-1-thread-2startTime : Wed Jul 06 21:04:26 IST 2016

请建议我应该使用哪个 api 来实现这一点。我希望 startTime 应该每 1 秒打印一次，无论它是否完成。

如果 coreSize 为 5，那么当 5 个线程已经在工作时，如果需要，ScheduledExecutorService 可以创建多少个新线程？

注意：我也尝试了 Timer 类的 scheduleAtFixedRate api，但这也不能解决我的目的。

Answer 1

以下是我的方法。请建议是否有更好的方法。

public static void main(String[] args) throws Exception {
     while(true){
         sleepForNSeconds(1);
         new Thread(new Test().new Mytask()).start();
     }

 }  

 class Mytask implements Runnable {

     public void run() {
         System.out.println(Thread.currentThread().getName()
                 + " startTime : " + new Date());
         sleepForNSeconds(5);
         System.out.println(Thread.currentThread().getName() + " endTime : "
                 + new Date());
     }
 } 

输出：

Thread-0 startTime : Wed Jul 06 21:41:47 IST 2016
Thread-1 startTime : Wed Jul 06 21:41:48 IST 2016
Thread-2 startTime : Wed Jul 06 21:41:49 IST 2016
Thread-3 startTime : Wed Jul 06 21:41:50 IST 2016
Thread-4 startTime : Wed Jul 06 21:41:51 IST 2016
Thread-0 endTime : Wed Jul 06 21:41:53 IST 2016
Thread-5 startTime : Wed Jul 06 21:41:53 IST 2016
Thread-1 endTime : Wed Jul 06 21:41:54 IST 2016  

Answer 2

使用scheduleAtFixedRate() 方法不是个好主意，就像docs 说的那样：

如果此任务的任何执行时间超过其周期，则后续执行可能会延迟开始，但不会同时执行。

您始终可以使用schedule() 方法并在开始时调用自己，也应该可以：

    ScheduledExecutorService scheduledPool = Executors.newScheduledThreadPool(5);
    scheduledPool.schedule(new Runnable(){
        public void run(){
            scheduledPool.schedule(this,1,TimeUnit.SECONDS);
            System.out.println(Thread.currentThread().getName() + "startTime : "+ new Date());
            try {
                Thread.sleep(5000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName()  +"endTime : "+ new Date());
        }
    },1, TimeUnit.SECONDS);
}