package jDKMulit;import java.util.concurrent.*;/** * Created by ycy on 16/1/12. */public class DviTask implements  Runnable{    int a,b;    public void run() {        double re=a/b;        System.out.println(re);    }    public DviTask(int a,int b){        this.a=a;        this.b=b;    }    public static void main(String[] args) throws ExecutionException, InterruptedException {        ThreadPoolExecutor pools= new ThreadPoolExecutor(0,Integer.MAX_VALUE,0l, TimeUnit.SECONDS,new SynchronousQueue
      
       ());        for (int i = 0; i <5 ; i++) {          //  pools.execute(new DviTask(100,i));            Future re= pools.submit(new DviTask(100,i));            re.get();        }    }}
      

2、扩展我们的线程池

package jDKMulit;import java.util.concurrent.*;/** * Created by ycy on 16/1/13. * 自己扩展线程池获取异常位置 * 重写submit:可以拉取异常 */public class VeryTraceThreadPoolExecutor extends ThreadPoolExecutor {    // 初始化    public VeryTraceThreadPoolExecutor(int corePoolSize, int maxmumPoolSize,                                       long keepAliveTime, TimeUnit unit, BlockingQueue
      
        workQueue){        super(corePoolSize,maxmumPoolSize,keepAliveTime,unit,workQueue);    }    //执行方法    @Override    public void execute(Runnable command) {        super.execute(command);    }    @Override    public Future
        submit(Runnable task) {        return super.submit(wrap(task,clientTrace(),Thread.currentThread().getName()));    }    private Exception clientTrace(){        //扔出异常        return new Exception("client stack trace");    }    private Runnable wrap(final Runnable task,final Exception clientStack,String clientThreadName){        return  new Runnable() {            public void run() {                try {                    task.run();                } catch (Exception e) {                    clientStack.printStackTrace();                    try {                        throw e;                    } catch (Exception e1) {                        e1.printStackTrace();                    }                }            }        };    }    public static void main(String[] args) {        ThreadPoolExecutor pools=new VeryTraceThreadPoolExecutor(0,Integer.MAX_VALUE,0l,TimeUnit.SECONDS,new SynchronousQueue
       
        ());        //错误堆栈中可以看到是在哪里提交的任务        for (int i = 0; i < 5; i++) {            pools.execute(new DviTask(100,i));        }    }}
       
      

java.lang.Exception: client stack trace	at jDKMulit.VeryTraceThreadPoolExecutor.clientTrace(VeryTraceThreadPoolExecutor.java:31)	at jDKMulit.VeryTraceThreadPoolExecutor.execute(VeryTraceThreadPoolExecutor.java:21)	at jDKMulit.VeryTraceThreadPoolExecutor.main(VeryTraceThreadPoolExecutor.java:57)	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)	at java.lang.reflect.Method.invoke(Method.java:606)	at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)java.lang.ArithmeticException: / by zero	at jDKMulit.DviTask.run(DviTask.java:12)	at jDKMulit.VeryTraceThreadPoolExecutor$1.run(VeryTraceThreadPoolExecutor.java:40)	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)	at java.lang.Thread.run(Thread.java:745)100.025.033.050.0