Java十分鐘入門多執行緒下篇

public class MyRunnable implements Runnable{

    int num;

    public MyRunnable(int num) {
        this.num = num;
    }

    @Override
    public void run() {
        
        System.out.println(Thread.currentThread().getName()+"執行了："+num);
    }
}

public class Test {
    public static void main(String[] args) {

        //建立單個執行緒池物件，裡面執行緒只有一個
        ExecutorService cachedService = Executors.newCachedThreadPool();

        //執行5個任務
        for (int i = 1; i<= 5; i++) {
            cachedService.execute(new MyRunnable(i));
        }
    }
}

public class Test {
    public static void main(String[] args) {
    
        //建立一個快取的執行緒池物件
       
        ExecutorService cachedService = Executors.newCachedThreadPool();
        
        for (int i = 1; i<= 5; i++) {
                cachedService.execute(new MyRunnable(i));
                //執行緒休眠：
                try{
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
        }
    }
}

public class Test {
    public static void main(String[] args) {

        //建立單個執行緒池物件，裡面執行緒只有一個
        ExecutorService singleService = Executors.newSingleThreadExecutor();

        //執行一百萬次任務
        for (int i = 1; i<= 1000000; i++) {
            singleService.execute(new MyRunnable(i));
        }
    }
}

public class Test {
    public static void main(String[] args) {

        //執行緒池建立固定數量的執行緒物件來執行任務，這裡建立10個執行緒物件，由執行緒池管理生命週期
        ExecutorService singleService = Executors.newFixedThreadPool(10);
        //執行10個任務
        for (int i = 1; i<= 100; i++) {
            singleService.execute(new MyRunnable(i));
        }
    }
}

public class MyRunnable implements Runnable{

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName()+"延遲5秒執行，並且每2秒執行一次該任務：");
    }
}

public class Test {
    public static void main(String[] args) {

        //執行緒池建立一個定時任務的執行緒物件
        ScheduledExecutorService service = Executors.newScheduledThreadPool(4);
        /**
         *定時器執行的任務，並且按週期執行
         * 引數1：執行緒任務
         * 引數2:5秒之後開始執行
         * 引數3：執行後每2秒為一個週期去迴圈執行
         * 引數4：時間單位。列舉型別，我這指定秒（可以參考API）
         */
        service.scheduleAtFixedRate(new MyRunnable(),5,1, TimeUnit.SECONDS);
    }
}

public class MyRunnable implements Runnable{

    int num;

    public MyRunnable(int i) {

        this.num = num;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName()+"執行了"+num);
    }
}

public class Test {
    public static void main(String[] args) {

        /**
         * 引數1：執行緒池有5個固定的執行緒物件
         * 引數2:當執行緒池的執行緒忙不過來的時候，最大執行緒數為7，也就是說執行緒物件就可以增加到7個（其中2個是臨時執行緒）
         * 引數3：當臨時執行緒物件超出300毫秒的時候還沒有接到新任務，執行緒池就自動 銷燬臨時的執行緒物件
         * 引數4：時間單位。這指定秒，具體參考TimeUnit的列舉型別
         * 引數5：等待執行的任務序列4個（其中有4個任務序列等待執行緒池物件來執行任務）
         */

        ThreadPoolExecutor executor = new ThreadPoolExecutor(5,7,300, 
        					TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(4));

        for (int i = 0; i < 6; i++) {
            executor.execute(new MyRunnable(i));
            showInfo(executor);
        }
    }

	//獲取執行緒的一些資訊
    private static void showInfo(ThreadPoolExecutor executor) {
        System.out.println("執行緒池的總數量："+executor.getPoolSize());
        System.out.println("佇列中等待執行的任務數："+executor.getQueue().size());
        System.out.println("已經執行完畢的任務數："+executor.getCompletedTaskCount());
        System.out.println("---------");
    }
}