newWorkStealingPool

DreamCats · DreamCats · commit 7d63a2b333de · 2020-01-01T15:10:54.000+08:00
diff --git a/Multithread/README.md b/Multithread/README.md
@@ -40,4 +40,5 @@ DelayQueue(执行定时任务)
 - newCachedThreadPool(带有缓存线程池，默认空闲线程60s)
 - newSingleThreadExecutor(单个线程)
 - newScheduledThreadPoold(定时线程池)
+- newWorkStealingPool(空闲线程去抢占其他线程的任务队列的任务)
 - 
diff --git a/Multithread/src/T28.java b/Multithread/src/T28.java
@@ -0,0 +1,49 @@
+import java.io.IOException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @program JavaBooks
+ * @description: 第五种，WorkStealingPool
+ * @author: mf
+ * @create: 2020/01/01 15:05
+ */
+
+
+public class T28 {
+    public static void main(String[] args) throws IOException {
+        // 默认核数
+        ExecutorService service = Executors.newWorkStealingPool();
+
+        service.execute(new R(1000));
+        service.execute(new R(2000));
+        service.execute(new R(2000));
+        service.execute(new R(2000));
+        service.execute(new R(2000));
+
+        // 由于产生的是精灵线程(守护线程、后台线程)，主线程如果不阻塞的话，看不到输出
+        System.in.read();
+
+        service.shutdown();
+    }
+
+    private static class R implements Runnable {
+
+        int time;
+
+        public R(int time) {
+            this.time = time;
+        }
+
+        @Override
+        public void run() {
+            try {
+                TimeUnit.MILLISECONDS.sleep(time);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+            System.out.println(Thread.currentThread().getName());
+        }
+    }
+}

Original file line number	Diff line number	Diff line change
`@@ -40,4 +40,5 @@ DelayQueue(执行定时任务)`
`40`	`40`	`- newCachedThreadPool(带有缓存线程池，默认空闲线程60s)`
`41`	`41`	`- newSingleThreadExecutor(单个线程)`
`42`	`42`	`- newScheduledThreadPoold(定时线程池)`
	`43`	`+- newWorkStealingPool(空闲线程去抢占其他线程的任务队列的任务)`
`43`	`44`	`-`