线程调度

package com.example.demo.thread.threadpool;

import java.util.Random;
import java.util.concurrent.*;

/**
 * 文件名：ScheduledThreadPool
 * 作 者：Miles zhu
 * 时 间：2019/7/30 9:49
 * -------------------------
 * 功能和描述：
 **/
public class TestScheduledThreadPool {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        ScheduledExecutorService pool = Executors.newScheduledThreadPool(5);
        for (int i = 0; i < 5; i++) {
            Future<Integer> future = pool.schedule(new Callable<Integer>() {
                @Override
                public Integer call() throws Exception {
                    int num = new Random().nextInt(100);
                    System.out.println(Thread.currentThread().getName() + "-" + num);
                    return num;
                }
            }, 3, TimeUnit.SECONDS);
            System.out.println(future.get());
        }
        pool.shutdown();
    }
}