https://www.cnblogs.com/stonefeng/p/5967451.html
在使用多线程的时候有时候我们会使用 java.util.concurrent.Executors的线程池,当多个线程异步执行的时候,我们往往不好判断是否线程池中所有的子线程都已经执行完毕,但有时候这种判断却很有用,例如我有个方法的功能是往一个文件异步地写入内容,我需要在所有的子线程写入完毕后在文件末尾写“---END---”及关闭文件流等,这个时候我就需要某个标志位可以告诉我是否线程池中所有的子线程都已经执行完毕,我使用这种方式来判断。
public class MySemaphore {
public static void main(String[] args) throws IOException, InterruptedException {
final File stream = new File("c:\\temp\\stonefeng\\stream.txt");
final OutputStream os = new FileOutputStream(stream);
final OutputStreamWriter writer = new OutputStreamWriter(os);
final Semaphore semaphore = new Semaphore(10);
ExecutorService exec = Executors.newCachedThreadPool();
final long start = System.currentTimeMillis();
for (int i = 0; i < 10000000; i++) {
final int num = i;
Runnable task = new Runnable() {
@Override
public void run() {
try {
semaphore.acquire();
writer.write(String.valueOf(num)+"\n");
semaphore.release();
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
exec.submit(task);
}
exec.shutdown();
while(true){
if(exec.isTerminated()){
writer.write("---END---\n");
writer.close();
System.out.println("所有的子线程都结束了!");
break;
}
Thread.sleep(1000);
}
final long end = System.currentTimeMillis();
System.out.println((end-start)/1000);
}
}
当调用ExecutorService.shutdown方法的时候,线程池不再接收任何新任务,但此时线程池并不会立刻退出,直到添加到线程池中的任务都已经处理完成,才会退出。在调用shutdown方法后我们可以在一个死循环里面用isTerminated方法判断是否线程池中的所有线程已经执行完毕,如果子线程都结束了,我们就可以做关闭流等后续操作了。
判断线程池中的线程是否全部执行完毕的另外一种解决方案则是使用闭锁(CountDownLatch)来实现,CountDownLatch是一种灵活的闭锁实现,它可以使一个或多个线程等待一组事件发生。闭锁状态包括一个计数器,该计数器被初始化为一个正数,表示需要等待的事件数量。countDown方法递减计数器,表示有一个事件已经发生了,而await方法等待计数器达到零,即表示需要等待的事情都已经发生。可以使用闭锁来这样设计程序达到目的:
1 public class CountDownLatchApproach {
2 public static void main(String[] args) throws IOException, InterruptedException {
3 final int nThreads = 10;
4 final CountDownLatch endGate = new CountDownLatch(nThreads);
5 final File stream = new File("c:\\temp\\stonefeng\\stream.txt");
6 final OutputStream os = new FileOutputStream(stream);
7 final OutputStreamWriter writer = new OutputStreamWriter(os);
8 ExecutorService exec = Executors.newCachedThreadPool();
9 for (int i = 0; i < nThreads; i++) {
10 final int num = i;
11 Runnable task = new Runnable() {
12 @Override
13 public void run() {
14 try {
15 writer.write(String.valueOf(num)+"\n");
16 } catch (IOException e) {
17 e.printStackTrace();
18 } finally {
19 endGate.countDown();
20 }
21 }
22 };
23 exec.submit(task);
24 }
25 endGate.await();
26 writer.write("---END---\n");
27 writer.close();
28 }
29 }
这种解决方案虽然可以达到目的但是性能差到没朋友,我更倾向于使用第一种方案。
现在我们有了更优雅的第三种方案,它的执行性能也不错。
1 public class MySemaphore {
2
3 public static void main(String[] args) throws IOException, InterruptedException {
4 final File stream = new File("c:\\temp\\stonefeng\\stream.txt");
5 final OutputStream os = new FileOutputStream(stream);
6 final OutputStreamWriter writer = new OutputStreamWriter(os);
7 final Semaphore semaphore = new Semaphore(10);
8 ExecutorService exec = Executors.newCachedThreadPool();
9
10 final long start = System.currentTimeMillis();
11 for (int i = 0; i < 10000000; i++) {
12 final int num = i;
13 Runnable task = new Runnable() {
14 @Override
15 public void run() {
16 try {
17 semaphore.acquire();
18 writer.write(String.valueOf(num)+"\n");
19 semaphore.release();
20 } catch (IOException e) {
21 e.printStackTrace();
22 } catch (InterruptedException e) {
23 e.printStackTrace();
24 }
25 }
26 };
27 exec.submit(task);
28 }
29 exec.shutdown();
30 exec.awaitTermination(1, TimeUnit.HOURS);
31 writer.write("---END---\n");
32 writer.close();
33 System.out.println("ËùÓеÄ×ÓÏ̶߳¼½áÊøÁË£¡");
34 final long end = System.currentTimeMillis();
35 System.out.println((end-start)/1000);
36 }
37 }
分享到:
相关推荐
C#判断线程池中所有的线程是否已经完成.doc
主要介绍了Java判断线程池线程是否执行完毕,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
这里线程池线程大小还需要判断一次;前面的判断过程中并没有加锁,因此可能在execute方法判断的时候poolSize小于corePoolSize,而判断完之后,在其他线程中又向线程池提交了任务,就可能导致poolSize不小于...
3.如果队列满了, 则判断线程池是否已满, 如果没满, 创建线程执行任务 4.如果线程池满了, 按照拒绝策略对任务进行处理 JDK中提供了一个线程池工厂: Executors ,很多工厂方法, 可以创建多种线程池 1.单一线程池 ...
数据量很大百万条记录,因此考虑到要用多线程并发执行,在写的过程中又遇到问题,我想统计所有子进程执行完毕总共的耗时,在第一个子进程创建前记录当前时间用System.currentTimeMillis()在后一个子进程结束后...
获取线程池状态是否彻底空闲,也就是说任务是否全部执行完毕,可以作为后续投递任务完任务后的判断。 15. 取_线程池容量() 获取线程池的可执行的最小线程数量 16. 取_最大线程容量() 获取线程池中可执行的最大...
1.通过一个主线程来监视是否有新任务,如果有新任务,则判断当前的线程数是否大于最大线程数,如果小于最大线程数则创建新线程,反之则加入线程队列等待执行。 2.当时间经过过长(1分钟,可手动设置)主线程会自动...
1.通过一个主线程来监视是否有新任务,如果有新任务,则判断当前的线程数是否大于最大线程数,如果小于最大线程数则创建新线程,反之则加入线程队列等待执行。 2.当时间经过过长(1 分钟,可手动设置)主线程会自动...
1.写出判断ABCD四个表达式的是否正确, 若正确, 写出经过表达式中 a的值(3分) int a = 4; (A)a += (a++); (B) a += (++a) ;(C) (a++) += a;(D) (++a) += (a++); a = ? 答:C错误,左侧不是一个有效变量,不能赋值,可...
微信方法是由Servlet在获取请求消息或事件的策略后取得,Servlet取得微信方法后,在线程池中获取线程执行微信方法。缺省线程池的大小是10个,如果微信公众并发比较频繁,我们可以调整线程池的大小,以提高处理效率。...