Java并发编程之复杂任务执行与跟踪

请思考以下的业务应用场景（很常见的一种业务应用场景）：

 

	/**
	 * 此例子演示用多线程编程方式读取N个复杂任务，并在前端界面中展现
	 * 此N个复杂任务的执行进度与情况（先处理完成的先在前端展现），直到
	 * 全部复杂任务处理完成后，在前端提示用户处理完毕并展现全部结果
	 * @param args
	 */

当处理一个比较耗时而且比较适用应用多线程编程环境的情况，如某些业务系统不联网，但查询的操作需要同时提取底下各个县市的查询结果，并在前端反应查询情况，先查到的数据现在前端显示，当全部查询完成后，触发一定的事件通知页面，这里我们主要应用JDK 1.5的java.util.concurrent包下的SDK。

 

首先声明一些线程池之类的东东，还有声明一个定时任务（主要用来模拟前端查询操作）：

 

 

public final static TaskResult tr = new TaskResult();
public final static ExecutorService exec = Executors.newFixedThreadPool(10);
public final static CompletionService serv = new ExecutorCompletionService(exec);
public final static ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

 

假设一个复杂任务，交由5个独立线程去处理，每个线程后的处理结果放到一个List中，处理代码一下：

 

 

		//假设该复杂任务分解成5个多线程任务
		for (int index = 0; index < 5; index++) {
			final int NO = index;
			Callable mytask = new Callable() {
				public String call() {
					//模拟任务需要耗费比较长的时间
					try {
						Thread.sleep((long) (Math.random() * 2000));
					} catch (InterruptedException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
					return "Task " + NO + " 处理完毕了，处理完毕时间："+(new Date());
				}
			};
			serv.submit(mytask);
		}
		//获取5个简单任务结果
		for (int index = 0; index < 5; index++) {
			Future task;
			try {
				task = serv.take();
				String res = (String) task.get(100,TimeUnit.MILLISECONDS);
				tr.getResult().add(res);
			} catch (InterruptedException e) {
				tr.getResult().add("当前任务"+index+"被中断返回结果...");
			} catch (ExecutionException e) {
				tr.getResult().add("当前任务"+index+"执行异常返回结果...");
			} catch (TimeoutException e) {
				tr.getResult().add("当前任务"+index+"超时返回结果...");
			}
		}
		
		tr.setFinish(true);

 

 前端模拟操作交由一个定时任务去处理（相当于利用Ａｊａｘ之类的技术去读取后台结果）：

 

 

		//前端程序模拟：启动单独线程每个200ms查看一下，taskresult中的结果值
		final Runnable beeper = new Runnable() { 
            public void run() { 
            	int i = tr.getResult().size();
            	boolean isok = tr.isFinish();    
            	System.out.println("当前复杂任务完成情况："+i+"/5" + ",是否完成："+isok);
            	if(isok){
            		scheduler.shutdown();
            		exec.shutdown();
            	}           	
            } 
        };    
	    final ScheduledFuture<?> beeperHandle = 
	        scheduler.scheduleAtFixedRate(beeper, 0, 200, TimeUnit.MILLISECONDS); 

最终的运行结果如下（利用Ａｊａｘ甚至可以做出进度条效果，体验非常好）：

 

当前复杂任务完成情况：0/5,是否完成：false
当前复杂任务完成情况：0/5,是否完成：false
当前复杂任务完成情况：0/5,是否完成：false
当前复杂任务完成情况：0/5,是否完成：false
当前复杂任务完成情况：0/5,是否完成：false
当前复杂任务完成情况：1/5,是否完成：false
当前复杂任务完成情况：1/5,是否完成：false
当前复杂任务完成情况：2/5,是否完成：false
当前复杂任务完成情况：2/5,是否完成：false
当前复杂任务完成情况：2/5,是否完成：false
当前复杂任务完成情况：3/5,是否完成：false
当前复杂任务完成情况：3/5,是否完成：false
当前复杂任务完成情况：3/5,是否完成：false
当前复杂任务完成情况：3/5,是否完成：false
当前复杂任务完成情况：3/5,是否完成：false
当前复杂任务完成情况：4/5,是否完成：false
当前复杂任务完成情况：4/5,是否完成：false
当前复杂任务完成情况：4/5,是否完成：false
当前复杂任务完成情况：4/5,是否完成：false
当前复杂任务完成情况：4/5,是否完成：false
当前复杂任务完成情况：5/5,是否完成：true