40 lines
1001 B
Java
40 lines
1001 B
Java
// lowlevel/WorkStealingPool.java
|
|
// (c)2016 MindView LLC: see Copyright.txt
|
|
// We make no guarantees that this code is fit for any purpose.
|
|
// Visit http://OnJava8.com for more book information.
|
|
import java.util.concurrent.*;
|
|
|
|
class ShowThread implements Runnable {
|
|
@Override
|
|
public void run() {
|
|
System.out.println(
|
|
Thread.currentThread().getName());
|
|
}
|
|
}
|
|
|
|
public class WorkStealingPool {
|
|
public static void main(String[] args)
|
|
throws InterruptedException {
|
|
System.out.println(
|
|
Runtime.getRuntime().availableProcessors());
|
|
ExecutorService exec =
|
|
Executors.newWorkStealingPool();
|
|
for(int i = 0; i < 10; i++)
|
|
exec.execute(new ShowThread());
|
|
exec.awaitTermination(1, TimeUnit.SECONDS);
|
|
}
|
|
}
|
|
/* Output:
|
|
8
|
|
ForkJoinPool-1-worker-1
|
|
ForkJoinPool-1-worker-2
|
|
ForkJoinPool-1-worker-1
|
|
ForkJoinPool-1-worker-1
|
|
ForkJoinPool-1-worker-4
|
|
ForkJoinPool-1-worker-1
|
|
ForkJoinPool-1-worker-3
|
|
ForkJoinPool-1-worker-5
|
|
ForkJoinPool-1-worker-4
|
|
ForkJoinPool-1-worker-2
|
|
*/
|