package threads;

import java.util.concurrent.*;

/**
 * created by flyketch
 * 19-9-19 上午10:48
 */
public class ThreadPoolTest {

    private static ExecutorService pool;

    public static void main(String[] args) {
        pool = new ThreadPoolExecutor(1, 2, 1000,
                TimeUnit.MILLISECONDS, new PriorityBlockingQueue<Runnable>(),
                Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());

        for(int i=0;i<10;i++) {
            pool.execute(new ThreadTask(i));
        }

//        pool = new ThreadPoolExecutor(1, 2, 1000,
//                TimeUnit.MILLISECONDS, new SynchronousQueue<Runnable>(),
//                Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());
//        for (int i = 0; i < 3; i++) {
//            pool.execute(new SyncQueueThreadTask());
//        }
    }
}