java线程池的初步使用和探究

ゝ一纸荒年。 2024-02-17 16:22 59阅读 0赞

上一篇文章中已经提到了线程池的概念，就是事先创建一部分的线程来准备这，到使用的时候在进行直接调用，这样就减少了资源不停的创建和销毁带来的消耗。创建的线程是你的策略，创建号之后在有一个任务的时候就调用一个线程去执行，执行完毕之后线程放回进线程池，等待下一个任务来调用。如果任务太多就造成线程阻塞，至于阻塞的线程怎么操作就要看你的线程的阻塞策略。至于线程的策略之后我们讨论。

好了我们来看一下今天的使用吧：实现Callable接口

Callable接口和Runnable 接口一样，也是实现java的并发编程，不同的是：1.Callable是重写了接口的Call方法，而Runnable是重写了run方法。1.Callable接口是有返回值的，而Runnable是没有返回值的。3.Callable的call方法可以抛出异常，而Runnable的run方法不能抛出异常。

public class Test {
        public static void main(String[] args) throws ExecutionException, InterruptedException {
            System.out.println("==========程序开始运行=========");
            Date date1 = new Date();
    
            //创建一个大小为5的线程池
            int taskSize = 5;
            ExecutorService pool = Executors.newFixedThreadPool(taskSize);
            List<Future> list = Lists.newArrayList();
            for (int i = 0; i < taskSize; i++) {
                Callable callable = new MyCallable(i + "");
                //执行任务并且获取Future对象
                Future future = pool.submit(callable);
                //用于结果收取
                list.add(future);
            }
            /**
             * 关闭线程池,线程的执行已经结束，只是结果分析，所以可以关闭线程池
             */
            pool.shutdown();
            for (Future future : list) {
                System.out.println("程序运行结果：" + future.get().toString());
            }
            Date date2 = new Date();
            System.out.println("=====程序运行结束=====,运行时间：【" + (date2.getTime() - date1.getTime()) + "】毫秒");
        }
     
     public class MyCallable implements Callable {
    
        private String taskNum;
    
        public MyCallable(String taskNum) {
            this.taskNum = taskNum;
        }
    
        @Override
        public Object call() throws Exception {
            System.out.println("======" + taskNum + "任务启动");
            Date dateTemp = new Date();
            Thread.sleep(1000);
            Date dateTemp2 = new Date();
            long time = dateTemp2.getTime() - dateTemp.getTime();
            System.out.println("======" + taskNum + "任务执行完毕");
            return taskNum + "任务返回运行结果,当前任务时间【" + time + "毫秒】";
        }
    } 
     今天有点事，先走了