线程池的使用

    @Autowired
    private rannableTest rannableTest;
    //当线程超过最大任务值时会抛出异常 SynchronousQueue
    //当线程池超过最大任务值时其余的会被缓存直至将缓存中全部处理完成，适用于短时间高并发 linkedBlockingDeque，吞吐量通常要高于ArrayBlockingQueue
    //PriorityBlockingQueue 对队列中的任务进行排序，业务：优先级执行等操作，或者从大到小 注:提交的任务必须实现Comparable方法
    //ArrayBlockingQueue 是一个有界限的队列，当队列容量超过本身缓存容量时会抛出异常，遵循着先进先出的原则
   private  ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(2, 20, 10000L, TimeUnit.SECONDS, new ArrayBlockingQueue(1000));
// 　　execute()方法实际上是Executor中声明的方法，在ThreadPoolExecutor进行了具体的实现，这个方法是ThreadPoolExecutor的核心方法，通过这个方法可以向线程池提交一个任务，交由线程池去执行。
//     submit()方法是在ExecutorService中声明的方法，在AbstractExecutorService就已经有了具体的实现，在ThreadPoolExecutor中并没有对其进行重写，这个方法也是用来向线程池提交任务的，但是它和execute()方法不同，它能够返回任务执行的结果，去看submit()方法的实现，会发现它实际上还是调用的execute()方法，只不过它利用了Future来获取任务执行结果（Future相关内容将在下一篇讲述）。
//     shutdown()和shutdownNow()是用来关闭线程池的。
//     还有很多其他的方法：
//     比如：getQueue() 、getPoolSize() 、getActiveCount()、getCompletedTaskCount()等获取与线程池相关属性的方法，有兴趣的朋友可以自行查阅API。
    @Test
    void contextLoads() throws Exception {
        for (int i = 0; i < 10000; i++) {
            threadPoolExecutor.execute(new rannableTest(i+"名字",i,i));
        }
        BlockingQueue queue = threadPoolExecutor.getQueue();
        System.out.println("queue = " + queue.toString());
    }