1 import java.io.IOException;

2 import java.util.concurrent.ExecutorService;

3 import java.util.concurrent.Executors;

4 import java.util.concurrent.TimeUnit;

5

6 /**

7 * 任务窃取算法

8 */

9 public class WorkStealingPool {

10

11 public static void main(String[] args) {

12

13 ExecutorService service = Executors.newWorkStealingPool();

14

15 System.out.println(Runtime.getRuntime().availableProcessors());

16

17 service.submit(new R(1)); //精灵线程

18 service.submit(new R(2));

19 service.submit(new R(2));

20 service.submit(new R(2));

21 service.submit(new R(2));

22

23 try {

24 System.in.read();

25 //由于产生的是精灵线程(守护线程、后台线程)，主程序不阻塞的话看不到打印信息

26 } catch (IOException e) {

27 e.printStackTrace();

28 }

29

30 }

31

32 static class R implements Runnable {

33

34 int time;

35

36 R(int runTime) {

37 this.time = runTime;

38 }

39

40 @Override

41 public void run() {

42 try {

43 TimeUnit.SECONDS.sleep(time);

44 } catch (InterruptedException e) {

45 e.printStackTrace();

46 }

47 System.out.println(time + " " + Thread.currentThread().getName());

48 }

49 }

50

51

newWorkStealingPool线程池的实现用到了ForkJoinPool，用到了分而治之，递归计算的算法，

标签：java,service,import,submit,线程,new,Java,WorkStealingPool

来源： https://www.cnblogs.com/mxh-java/p/12246488.html