-
Notifications
You must be signed in to change notification settings - Fork 1
Expand file tree
/
Copy pathThreadPoolTest.java
More file actions
43 lines (40 loc) · 1.53 KB
/
ThreadPoolTest.java
File metadata and controls
43 lines (40 loc) · 1.53 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
package org.cp;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
/**
* Executors.newFixedThreadPool 简单用法
* create by CP on 2019/7/30 0030.
*/
public class ThreadPoolTest {
public static void main(String[] args) {
ExecutorService service = Executors.newFixedThreadPool(10);
ThreadPoolExecutor executor = (ThreadPoolExecutor) service;
Runnable runnable1 = () -> run1();
Runnable runnable2 = () -> run1();
Callable callable = () -> {
run1();
return null;
};
System.out.println(executor.getCorePoolSize());//核心线程数量，初始化为 10
executor.setCorePoolSize(12);//设置核心线程数 12
System.out.println(executor.getPoolSize());//活动的线程数，现在没有活动线程，为0
service.execute(runnable1);
service.execute(runnable1);
executor.execute(runnable2);
executor.submit(callable);
System.out.println(executor.getCorePoolSize());//这里为设置过的核心线程数 12
System.out.println(executor.getPoolSize());//加了4个任务进来，活动线程数为 4
}
private static void run1() {
while (true) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName());
}
}
}