package com.java110.log.executor;

import junit.framework.Test;
import junit.framework.TestCase;
import junit.framework.TestSuite;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/**
 * Created by wuxw on 2017/4/25.
 */
public class ExecutorTest  extends TestCase
{
    /**
     * Create the test case
     *
     * @param testName name of the test case
     */
    public ExecutorTest( String testName )
    {
        super( testName );
    }

    /**
     * @return the suite of tests being tested
     */
    public static Test suite()
    {
        return new TestSuite( ExecutorTest.class );
    }

    public void testThrowException(){
        ExecutorService executorService = Executors.newFixedThreadPool(100);

        int i = 0;
        List<Future<Integer>> futureList = new ArrayList<Future<Integer>>();
        while(i < 5) {
            Future<Integer> sum = executorService.submit(new PrintInt());
            i++;
            futureList.add(sum);
        }

        for(Future<Integer> sum : futureList) {
            try{

                    System.out.println(sum.get());

            }catch (Exception e){
                System.out.println("异常了");
                e.printStackTrace();
            }
        }
    }

    public void testThrowException1(){
        ExecutorService executorService = Executors.newFixedThreadPool(100);

        int i = 0;
        while(i < 5) {
            Future<Integer> sum = executorService.submit(new PrintInt());
            i++;

            try{

                System.out.println(sum.get());

            }catch (Exception e){
                System.out.println("异常了");
                e.printStackTrace();
            }

        }

    }

}