51Testing软件测试论坛

标题: 【我分享】java并行执行多个任务 [打印本页]

作者: 张亚洲 时间: 2015-1-6 08:40
标题: 【我分享】java并行执行多个任务
java并行执行多个任务：
最近做项目中，有个任务需要实现并发编程，个人参考了下网上的实现，自己实现了下并发方法，并且增加了简单的说明，希望的有需要的朋友有些帮助。

[java] [url=]view plaincopy[/url]

<pre code_snippet_id="202406" snippet_file_name="blog_20140224_1_9891540" name="code" class="java">import java.util.UUID;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* 测试监控类
*
* @author
*
*/
public class WatchThread {
private String name = UUID.randomUUID().toString();
/**
* 测试函数
*
* @throws InterruptedException
*/
public void testThread() throws InterruptedException {
int threadNum = 10;
// 初始化countDown
CountDownLatch threadSignal = new CountDownLatch(threadNum);
// 创建固定长度的线程池
// Executor executor = Executors.newFixedThreadPool(threadNum);
//此处不可以用接口需要使用Executor的实现类 ExecutorService Executor未提供shutdown等方法
ExecutorService executor = Executors.newFixedThreadPool(threadNum);
for (int i = 0; i < threadNum; i++) { // 开threadNum个线程
Runnable task = new TestThread(threadSignal);
// 执行
executor.execute(task);
}
threadSignal.await(); // 等待所有子线程执行完
//固定线程池执行完成后将释放掉资源退出主进程
executor.shutdown();//并不是终止线程的运行，而是禁止在这个Executor中添加新的任务
// do work end
//退出主进程
System.out.println(Thread.currentThread().getName() + "+++++++结束.");
}
/**
* 测试函数
*/
public static void main(String[] args) throws InterruptedException {
WatchThread test = new WatchThread();
test.testThread();
}
/**
*
* @author wangmuming
* 此可以做完内部类也可以不做未内部类
* 作为内部类的时候有一个好处就是可以直接引用给类的主对象的成员变量如此处的name
* 当然
*/
private class TestThread implements Runnable {
private CountDownLatch threadsSignal;
public TestThread(CountDownLatch threadsSignal) {
this.threadsSignal = threadsSignal;
}
public void run() {
System.out.println(Thread.currentThread().getName() + "开始..." + name);
System.out.println("开始了线程：：：：" + threadsSignal.getCount());
// do shomething
//核心处理逻辑
// 用到成员变量name作为参数
// 线程结束时计数器减1
threadsSignal.countDown();//必须等核心处理逻辑处理完成后才可以减1
System.out.println(Thread.currentThread().getName() + "结束. 还有"
+ threadsSignal.getCount() + " 个线程");
}
}
}</pre>
<pre></pre>
<pre></pre>
执行结果：
pool-1-thread-1开始...aaa917dc-bd69-4438-9bb1-0051e5c62984
开始了线程：：：：10
pool-1-thread-1结束. 还有9 个线程
pool-1-thread-2开始...aaa917dc-bd69-4438-9bb1-0051e5c62984
开始了线程：：：：9
pool-1-thread-2结束. 还有8 个线程
pool-1-thread-3开始...aaa917dc-bd69-4438-9bb1-0051e5c62984
开始了线程：：：：8
pool-1-thread-3结束. 还有7 个线程
pool-1-thread-4开始...aaa917dc-bd69-4438-9bb1-0051e5c62984
pool-1-thread-5开始...aaa917dc-bd69-4438-9bb1-0051e5c62984
开始了线程：：：：7
开始了线程：：：：7
pool-1-thread-4结束. 还有6 个线程
pool-1-thread-5结束. 还有5 个线程
pool-1-thread-10开始...aaa917dc-bd69-4438-9bb1-0051e5c62984
开始了线程：：：：5
pool-1-thread-6开始...aaa917dc-bd69-4438-9bb1-0051e5c62984
pool-1-thread-9开始...aaa917dc-bd69-4438-9bb1-0051e5c62984
开始了线程：：：：4
pool-1-thread-9结束. 还有3 个线程
pool-1-thread-8开始...aaa917dc-bd69-4438-9bb1-0051e5c62984
开始了线程：：：：3
pool-1-thread-8结束. 还有2 个线程
pool-1-thread-7开始...aaa917dc-bd69-4438-9bb1-0051e5c62984
开始了线程：：：：2
pool-1-thread-7结束. 还有1 个线程
开始了线程：：：：4
pool-1-thread-10结束. 还有4 个线程
pool-1-thread-6结束. 还有0 个线程
main+++++++结束.

欢迎光临 51Testing软件测试论坛 (http://bbs.51testing.com/)