java线程池——接收线程运行后返回的结果

淩亂°似流年 2022-09-27 15:22 176阅读 0赞

# java线程池——接收线程运行后返回的结果 #

java1.5新加入了线程同步的包。java.util.concurrent

其中有接口ExecutorService。

![Center][]

Executor提供了管理线程结束的方法，通过Future接口，能够跟踪一个或者多个异步线程运行的结果。

ExecutorService能够被shutdown，shutdown后，拒绝提交新的任务。ExecutorSerivce提供了两种shutdown的方式。shutdown()方法让先前已经提交的任务在终止操作前继续执行，而shutdownNow()方法阻止正在等待的线程启动，并且尝试终止当前正在运行的进程。终止线程后，Executor没有活跃的线程需要执行，也没有新的任务线程被提交。一个没有使用的ExecuteService应该被关闭，并且释放占用的资源。

Submit方法继承自Executor.execute(java.long.Runnable)方法，并且返回Future用来取消线程执行或者等待线程完成。invokeAny和invokeAll方法在执行大量线程时很常用。

Executors类提供了ExecutorService接口的工厂实现。

好，下面上货。

package com.xueyoucto.xueyou;
    
    import java.util.concurrent.Callable;
    
    public class ThreadReturnValue implements Callable {
        @Override
        public Object call() throws Exception {
            int temp = 0;
            StringBuffer sb = new StringBuffer("");
            synchronized (App.GLOBALARRAY) {
                for (int i = 0; i < App.GLOBALARRAY.length; i++) {
                    System.out.println(Thread.currentThread().getName() + "\n" + App.GLOBALARRAY[i]);
                    App.GLOBALARRAY[i] += 1;
                    temp += App.GLOBALARRAY[i];
                    sb.append("+").append(App.GLOBALARRAY[i]);
                }
            }
            return sb.toString() + "=" + temp;
        }
    }

package com.xueyoucto.xueyou;
    
    
    import java.util.concurrent.*;
    
    /**
     * Hello world!
     */
    public class App {
        public static int[] GLOBALARRAY = new int[50];
    
        public static ThreadLocal<String[]> TLGLOBALARRAY = new ThreadLocal<String[]>() {
            @Override
            protected String[] initialValue() {
                String[] temp = new String[50];
                for (int i = 0; i < temp.length; i++) {
                    temp[i] = String.valueOf(i + 100);
                }
                return temp;
            }
        };
    
        static {
            for (int i = 0; i < GLOBALARRAY.length; i++) {
                GLOBALARRAY[i] = i;
            }
        }
    
        public static void main(String[] args) {
            ExecutorService pool = Executors.newFixedThreadPool(3);
            Future<String> future = pool.submit(new ThreadReturnValue());
            Future<String> future2 = pool.submit(new ThreadReturnValue());
            Future<String> future3 = pool.submit(new ThreadReturnValue());
            pool.shutdown(); // 不允许再想线程池中增加线程
            //判断是否所有线程已经执行完毕
            try {
                boolean isFinish = pool.awaitTermination(1, TimeUnit.HOURS);
                System.out.println(isFinish + "==========================");
                //如果没有执行完
                if (!isFinish) {
                    //线程池执行结束 不在等待线程执行完毕，直接执行下面的代码
                    pool.shutdownNow();
                }
                String r = future.get();
                String r2 = future2.get();
                String r3 = future3.get();
    
                System.out.println(r);
                System.out.println(r2);
                System.out.println(r3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
            //只给线程池中的线程1小时，然后就继续执行
            System.out.println("it is ok !!!");
        }
    }

运行结果：

![Center 1][]

需要注意的是ExecutorService提供的是线程池的功能，并没有提供线程同步、互斥等功能，所以还是需要在互斥访问的变量上进行处理的。下面是没有处理的代码和结果，可以对比一下。

package com.xueyoucto.xueyou;
    
    import java.util.concurrent.Callable;
    
    public class ThreadReturnValue implements Callable {
        @Override
        public Object call() throws Exception {
            int temp = 0;
            StringBuffer sb = new StringBuffer("");
            for (int i = 0; i < App.GLOBALARRAY.length; i++) {
                System.out.println(Thread.currentThread().getName() + "\n" + App.GLOBALARRAY[i]);
                App.GLOBALARRAY[i] += 1;
                temp += App.GLOBALARRAY[i];
                sb.append("+").append(App.GLOBALARRAY[i]);
            }
            return sb.toString() + "=" + temp;
        }
    }

运行结果（注意最后的结果）：

![Center 2][]

[Center]: /images/20220708/44faac30b79b4c09aab468439bf05218.png
[Center 1]: /images/20220708/9e50ea38c88648e6b18267dd33519f79.png
[Center 2]: /images/20220708/c258263705f747309832afbe0c713388.png