Think_in_java_4th(並發學習二)
阿新 • • 發佈:2018-10-26
ring sample argument [] span 使用 static shutdown rgs
使用Executor
java.util.concurrent
CachedThreadPool
package concurrency.ExecutorService; //: concurrency/CachedThreadPool.java import java.util.concurrent.*; import concurrency.LiftOff.LiftOff; public class CachedThreadPool { public static void main(String[] args) { ExecutorService exec = Executors.newCachedThreadPool();for (int i = 0; i < 5; i++) exec.execute(new LiftOff()); exec.shutdown(); } } /* * Output: (Sample) #0(9), #0(8), #1(9), #2(9), #3(9), #4(9), #0(7), #1(8), * #2(8), #3(8), #4(8), #0(6), #1(7), #2(7), #3(7), #4(7), #0(5), #1(6), #2(6), * #3(6), #4(6), #0(4), #1(5), #2(5), #3(5), #4(5), #0(3), #1(4), #2(4), #3(4), * #4(4), #0(2), #1(3), #2(3), #3(3), #4(3), #0(1), #1(2), #2(2), #3(2), #4(2), * #0(Liftoff!), #1(1), #2(1), #3(1), #4(1), #1(Liftoff!), #2(Liftoff!), * #3(Liftoff!), #4(Liftoff!),*/// :~
FixedThreadPool
package concurrency.ExecutorService; //: concurrency/FixedThreadPool.java import java.util.concurrent.*; import concurrency.LiftOff.LiftOff; public class FixedThreadPool { public static void main(String[] args) { // Constructor argument is number of threads: ExecutorService exec = Executors.newFixedThreadPool(5);for (int i = 0; i < 5; i++) exec.execute(new LiftOff()); exec.shutdown(); } } /* * Output: (Sample) #0(9), #0(8), #1(9), #2(9), #3(9), #4(9), #0(7), #1(8), * #2(8), #3(8), #4(8), #0(6), #1(7), #2(7), #3(7), #4(7), #0(5), #1(6), #2(6), * #3(6), #4(6), #0(4), #1(5), #2(5), #3(5), #4(5), #0(3), #1(4), #2(4), #3(4), * #4(4), #0(2), #1(3), #2(3), #3(3), #4(3), #0(1), #1(2), #2(2), #3(2), #4(2), * #0(Liftoff!), #1(1), #2(1), #3(1), #4(1), #1(Liftoff!), #2(Liftoff!), * #3(Liftoff!), #4(Liftoff!), */// :~
SingleThreadExecutor
package concurrency.ExecutorService; //: concurrency/SingleThreadExecutor.java import java.util.concurrent.*; import concurrency.LiftOff.LiftOff; public class SingleThreadExecutor { public static void main(String[] args) { ExecutorService exec = Executors.newSingleThreadExecutor(); for (int i = 0; i < 5; i++) exec.execute(new LiftOff()); exec.shutdown(); } } /* * Output: #0(9), #0(8), #0(7), #0(6), #0(5), #0(4), #0(3), #0(2), #0(1), * #0(Liftoff!), #1(9), #1(8), #1(7), #1(6), #1(5), #1(4), #1(3), #1(2), #1(1), * #1(Liftoff!), #2(9), #2(8), #2(7), #2(6), #2(5), #2(4), #2(3), #2(2), #2(1), * #2(Liftoff!), #3(9), #3(8), #3(7), #3(6), #3(5), #3(4), #3(3), #3(2), #3(1), * #3(Liftoff!), #4(9), #4(8), #4(7), #4(6), #4(5), #4(4), #4(3), #4(2), #4(1), * #4(Liftoff!), */// :~
參考
Java編程思想(第4版) 656頁開始
Thinking in Java(第四版 ) 1120頁開始
Think_in_java_4th(並發學習二)