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

總結

以上是生活随笔為你收集整理的java work stealing_Java线程池之WorkStealingPool，任务窃取算法的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。