public class MultithreadingTest extends Thread{
    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            System.out.println("這是線程"+i+currentThread().getName());
        }
    }

    public static void main(String[] args) {
        MultithreadingTest mt=new MultithreadingTest();
        mt.start();//Exception in thread "main" java.lang.IllegalThreadStateException
        MultithreadingTest mt1=new MultithreadingTest();
        mt1.start();
        //mt.start();
    }
}

class RunnableTest implements Runnable{
    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            System.out.println("這是Runnable線程"+i+"-->"+Thread.currentThread().getName());
        }
    }

    public static void main(String[] args) {
        RunnableTest rt=new RunnableTest();
        Thread t1=new Thread(rt,"t1");
        Thread t2=new Thread(rt,"t2");
        Thread t3=new Thread(rt,"t3");
        t1.start();
        t2.start();
        t3.start();
    }
}

class CallableTest implements Callable {
    @Override
    public Object call() throws Exception {
        int num=0;
        for (int i = 1; i <= 100; i++) {
            if (i%2==0) {
                System.out.println(i);
                num += i;
            }
        }
        return num;
    }

    public static void main(String[] args) {
        CallableTest ct=new CallableTest();
        FutureTask ft=new FutureTask(ct);
        new Thread(ft).start();
        try {
            int i= (Integer) ft.get();
            System.out.println("總和為："+i);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }
}

/**
* 線程池相關(guān)API：ExecutorService和Excutors
* ExcutorService:真正的線程池接口；常見的子類ThreadPoolExcutor
*   1.void execute(Runnable command):執(zhí)行任務(wù)/命令，沒有返回值，一般用來執(zhí)行Runnable
*  2.<T>Future<T> submit(Callable<T> task):執(zhí)行任務(wù)，有返回值，一般用來執(zhí)行Callable
*  3.void shutdown():關(guān)閉連接池
* Executors:工具類、線程池的工廠類，用于創(chuàng)建并返回不同類型的線程池
*  1.Executors.newCachedThreadPool():創(chuàng)建一個(gè)可根據(jù)需要?jiǎng)?chuàng)建新線程的線程池
*  2.Executors.newFixedThreadPool(n):創(chuàng)建一個(gè)可重用固定線程數(shù)的線程池
*  3.Executors.newSingleThreadExecutor():創(chuàng)建一個(gè)只有一個(gè)線程的線程池
*  4.Executors.newScheduledThreadPool(n):創(chuàng)建一個(gè)線程池，它可安排在給定延遲后運(yùn)行命令或定期地執(zhí)行
*/
class CallAbleTest implements Callable<Boolean>{
    @Override
    public Boolean call() throws Exception {
        for (int i = 0; i < 100; i++) {
            System.out.println("這是Callable線程"+i+"-->"+Thread.currentThread().getName());
        }
        return true;
    }

    public static void main(String[] args) {
        CallAbleTest ct=new CallAbleTest();

        //創(chuàng)建執(zhí)行服務(wù)
        ExecutorService es= Executors.newFixedThreadPool(3);
        //提交執(zhí)行
        Future<Boolean> f1=es.submit(ct);
        Future<Boolean> f2=es.submit(ct);
        Future<Boolean> f3=es.submit(ct);
        Future<Boolean> f4=es.submit(ct);
        //獲取結(jié)果
        try {
            boolean r1=f1.get();
            boolean r2=f2.get();
            boolean r3=f3.get();
            boolean r4=f4.get();
            System.out.println("r1 = " + r1+" r2 = " + r2+" r3 = " + r3+" r4="+r4);;
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
        //關(guān)閉服務(wù)
        es.shutdownNow();
    }
}