基于队列的线程池
|
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
import
java.text.SimpleDateFormat;
import
java.util.Date;
import
java.util.concurrent.ArrayBlockingQueue;
import
java.util.concurrent.ThreadPoolExecutor;
import
java.util.concurrent.TimeUnit;
public
class
TestThreadPool {
// public static BlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(10);
public
static
ArrayBlockingQueue<Runnable> queue =
new
ArrayBlockingQueue<Runnable>(
10
);
public
static
void
main(String[] args) {
for
(
int
i =
0
; i <
3
; i++) {
queue.add(
new
TestThread(
"初始化"
));
}
final
ThreadPoolExecutor executor =
new
ThreadPoolExecutor(
2
,
3
,
15
, TimeUnit.SECONDS, queue);
System.out.println(
"getActiveCount="
+ executor.getActiveCount()
+
";getKeepAliveTime="
+ executor.getKeepAliveTime(TimeUnit.SECONDS)
+
";getCompletedTaskCount="
+ executor.getCompletedTaskCount()
+
";getCorePoolSize="
+ executor.getCorePoolSize()
+
";getLargestPoolSize="
+ executor.getLargestPoolSize()
+
";getMaximumPoolSize="
+ executor.getMaximumPoolSize()
+
";getPoolSize="
+ executor.getPoolSize()
+
";getTaskCount="
+ executor.getTaskCount()
+
";getQueue().size()="
+ executor.getQueue().size()
);
executor.execute(queue.poll());
System.out.println(
"getActiveCount="
+ executor.getActiveCount()
+
";getKeepAliveTime="
+ executor.getKeepAliveTime(TimeUnit.SECONDS)
+
";getCompletedTaskCount="
+ executor.getCompletedTaskCount()
+
";getCorePoolSize="
+ executor.getCorePoolSize()
+
";getLargestPoolSize="
+ executor.getLargestPoolSize()
+
";getMaximumPoolSize="
+ executor.getMaximumPoolSize()
+
";getPoolSize="
+ executor.getPoolSize()
+
";getTaskCount="
+ executor.getTaskCount()
+
";getQueue().size()="
+ executor.getQueue().size()
);
new
Thread(
new
Runnable() {
@Override
public
void
run() {
while
(
true
) {
System.out.println(
"getActiveCount="
+ executor.getActiveCount()
+
";getKeepAliveTime="
+ executor.getKeepAliveTime(TimeUnit.SECONDS)
+
";getCompletedTaskCount="
+ executor.getCompletedTaskCount()
+
";getCorePoolSize="
+ executor.getCorePoolSize()
+
";getLargestPoolSize="
+ executor.getLargestPoolSize()
+
";getMaximumPoolSize="
+ executor.getMaximumPoolSize()
+
";getPoolSize="
+ executor.getPoolSize()
+
";getTaskCount="
+ executor.getTaskCount()
+
";getQueue().size()="
+ executor.getQueue().size()
);
try
{
Thread.currentThread().sleep(1000L);
}
catch
(InterruptedException e) {
e.printStackTrace();
}
}
}
}).start();
new
Thread(
new
Runnable() {
@Override
public
void
run() {
int
i =
0
;
while
(
true
) {
queue.add(
new
TestThread(
"生产者"
));
try
{
Thread.currentThread().sleep(500L);
}
catch
(InterruptedException e) {
e.printStackTrace();
}
i++;
if
(i >
10
)
break
;
}
}
}).start();
}
}
class
TestThread
implements
Runnable {
public
static
SimpleDateFormat sdf =
new
SimpleDateFormat(
"yyyy-MM-dd HH:mm:ss"
);
private
String name;
//创建者
private
Date addDate;
//添加到队列的日期
TestThread(String name) {
this
.name = name;
this
.addDate =
new
Date();
}
@Override
public
void
run() {
System.out.println(Thread.currentThread().getName() +
"：创建者="
+ name +
"，创建时间="
+ sdf.format(addDate) +
"，执行时间="
+ sdf.format(
new
Date()) +
",当前队列大小="
+ TestThreadPool.queue.size());
try
{
Thread.currentThread().sleep(1000L);
}
catch
(InterruptedException e) {
e.printStackTrace();
}
}
}
|
执行结果：
|
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=0;getCorePoolSize=2;getLargestPoolSize=0;getMaximumPoolSize=3;getPoolSize=0;getTaskCount=3;getQueue().size()=3
getActiveCount=1;getKeepAliveTime=15;getCompletedTaskCount=0;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=3;getQueue().size()=2
pool-1-thread-1：创建者=初始化，创建时间=2014-08-20 12:08:19，执行时间=2014-08-20 12:08:19,当前队列大小=2
getActiveCount=1;getKeepAliveTime=15;getCompletedTaskCount=0;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=3;getQueue().size()=2
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=1;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=6;getQueue().size()=4
pool-1-thread-1：创建者=初始化，创建时间=2014-08-20 12:08:19，执行时间=2014-08-20 12:08:20,当前队列大小=4
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=2;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=8;getQueue().size()=5
pool-1-thread-1：创建者=初始化，创建时间=2014-08-20 12:08:19，执行时间=2014-08-20 12:08:21,当前队列大小=5
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=3;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=10;getQueue().size()=6
pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:19，执行时间=2014-08-20 12:08:22,当前队列大小=6
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=4;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=12;getQueue().size()=7
pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:19，执行时间=2014-08-20 12:08:23,当前队列大小=7
getActiveCount=1;getKeepAliveTime=15;getCompletedTaskCount=5;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=8
pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:20，执行时间=2014-08-20 12:08:24,当前队列大小=8
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=6;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=7
pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:20，执行时间=2014-08-20 12:08:25,当前队列大小=7
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=7;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=6
pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:21，执行时间=2014-08-20 12:08:26,当前队列大小=6
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=8;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=5
pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:21，执行时间=2014-08-20 12:08:27,当前队列大小=5
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=9;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=4
pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:22，执行时间=2014-08-20 12:08:28,当前队列大小=4
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=10;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=3
pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:22，执行时间=2014-08-20 12:08:29,当前队列大小=3
getActiveCount=1;getKeepAliveTime=15;getCompletedTaskCount=11;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=2
pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:23，执行时间=2014-08-20 12:08:30,当前队列大小=2
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=12;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=1
pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:23，执行时间=2014-08-20 12:08:31,当前队列大小=1
getActiveCount=1;getKeepAliveTime=15;getCompletedTaskCount=12;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=1
pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:24，执行时间=2014-08-20 12:08:32,当前队列大小=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
Process
finished with exit code -1
|
这个是理想情况，如果生产者创建速度大于消费者速度，则会随着时间推移耗尽系统资源，这个需要通过RejectedExecutionHandler来实现。
对这个例子，做了一些改动，可以更加清楚看到执行过程：
|
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
import
java.text.SimpleDateFormat;
import
java.util.Date;
import
java.util.concurrent.ArrayBlockingQueue;
import
java.util.concurrent.LinkedBlockingQueue;
import
java.util.concurrent.ThreadPoolExecutor;
import
java.util.concurrent.TimeUnit;
public
class
TestThreadPool {
// public static BlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(10);
// public static ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(10);
// public static ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(10);
public
static
LinkedBlockingQueue<Runnable> queue =
new
LinkedBlockingQueue<Runnable>();
public
static
void
main(String[] args) {
for
(
int
i =
0
; i <
2
; i++) {
queue.add(
new
TestThread(
"初始化"
));
}
final
ThreadPoolExecutor executor =
new
ThreadPoolExecutor(
1
,
3
,
15
, TimeUnit.SECONDS, queue);
// System.out.println("getActiveCount=" + executor.getActiveCount()
// + ";getKeepAliveTime=" + executor.getKeepAliveTime(TimeUnit.SECONDS)
// + ";getCompletedTaskCount=" + executor.getCompletedTaskCount()
// + ";getCorePoolSize=" + executor.getCorePoolSize()
// + ";getLargestPoolSize=" + executor.getLargestPoolSize()
// + ";getMaximumPoolSize=" + executor.getMaximumPoolSize()
// + ";getPoolSize=" + executor.getPoolSize()
// + ";getTaskCount=" + executor.getTaskCount()
// + ";getQueue().size()=" + executor.getQueue().size()
// );
// executor.execute(new Thread());
executor.prestartCoreThread();
// System.out.println("getActiveCount=" + executor.getActiveCount()
// + ";getKeepAliveTime=" + executor.getKeepAliveTime(TimeUnit.SECONDS)
// + ";getCompletedTaskCount=" + executor.getCompletedTaskCount()
// + ";getCorePoolSize=" + executor.getCorePoolSize()
// + ";getLargestPoolSize=" + executor.getLargestPoolSize()
// + ";getMaximumPoolSize=" + executor.getMaximumPoolSize()
// + ";getPoolSize=" + executor.getPoolSize()
// + ";getTaskCount=" + executor.getTaskCount()
// + ";getQueue().size()=" + executor.getQueue().size()
// );
new
Thread(
new
Runnable() {
@Override
public
void
run() {
while
(
true
) {
System.out.println(
"getActiveCount="
+ executor.getActiveCount()
+
";getKeepAliveTime="
+ executor.getKeepAliveTime(TimeUnit.SECONDS)
+
";getCompletedTaskCount="
+ executor.getCompletedTaskCount()
+
";getCorePoolSize="
+ executor.getCorePoolSize()
+
";getLargestPoolSize="
+ executor.getLargestPoolSize()
+
";getMaximumPoolSize="
+ executor.getMaximumPoolSize()
+
";getPoolSize="
+ executor.getPoolSize()
+
";getTaskCount="
+ executor.getTaskCount()
+
";getQueue().size()="
+ executor.getQueue().size()
);
try
{
Thread.currentThread().sleep(200L);
}
catch
(InterruptedException e) {
e.printStackTrace();
}
}
}
}).start();
new
Thread(
new
Runnable() {
@Override
public
void
run() {
int
i =
0
;
while
(
true
) {
queue.add(
new
TestThread(
"生产者"
));
try
{
Thread.currentThread().sleep(100L);
}
catch
(InterruptedException e) {
e.printStackTrace();
}
i++;
if
(i >
100
)
break
;
}
}
}).start();
}
}
class
TestThread
implements
Runnable {
public
static
SimpleDateFormat sdf =
new
SimpleDateFormat(
"yyyy-MM-dd HH:mm:ss"
);
private
String name;
//创建者
private
Date addDate;
//添加到队列的日期
TestThread(String name) {
this
.name = name;
this
.addDate =
new
Date();
}
@Override
public
void
run() {
System.out.println(Thread.currentThread().getName() +
"：创建者="
+ name +
"，创建时间="
+ sdf.format(addDate) +
"，执行时间="
+ sdf.format(
new
Date()) +
",当前队列大小="
+ TestThreadPool.queue.size());
System.out.println(TestThreadPool.queue.peek());
try
{
Thread.currentThread().sleep(1000L);
}
catch
(InterruptedException e) {
e.printStackTrace();
}
}
}
|
本文转自 leizhimin 51CTO博客，原文链接：http://blog.51cto.com/lavasoft/1542298，如需转载请自行联系原作者
