Java并行开发笔记3.2

  关于页面渲染的不同操作解析:

问题：一般地，对HTML文档进行处理时，当遇到文本标签时，将其绘制到图像缓存中。当遇到图像引用时，先通过网络获取它，然后再将其绘制到图像缓存中。

 

     1. 串行地渲染页面元素，即普通的网页页面中图片和文本同时加载

public class SingleThreadRenderer{
   void renderPage(CharSequence source){
       renderText(source);  //渲染文本
       List<ImageData> imageData = new ArrayList<ImageData>();
       for(ImageInfo imageInfo : scanForImageInfo(source))
       {
           imageData.add(imageInfo.downloadImage());
       }
       for(ImageData data : imageData)
       {
          renderImage(data);
       }

   }
}

 

   2. 使用Future等待图像下载，即稍微高级点页面内容加载成功后，等待图片加载。FutureRender使得渲染文本任务与下载图像数据的任务并发地执行。

 

public class FutureRender{
    private final ExecutorService executor = ...;
   
    void renderPage(CharSequence source){
          final List<ImageInfo> imageInfos = scanForImageInfo(source);
          Callable<List<ImageData>> task =
                new Callable<List<ImageData>>(){
                      public List<ImageData> call(){
                         List<ImageData> result = new ArrayList<ImageData>();
                         for(ImageInfo imageInfo : imageInfos)
                         {
                            result.add(imageInfo.downloadImage());
                         }
                         return result;
                      }
                };
        
         Future<List<ImageData>> future = executor.submit(task);
         renderText(source);

         try{
             List<ImageData> imageData = future.get();
             for(ImageData data : imageData)
                  renderImage(data);  
         }catch(InterruptedExcepiton e){
             //重新设置线程的中断状态
             Thread.currentThread().interrupt();
             //由于不需要结果，因此取消任务
             future.cancel(true);
         }catch(ExecutionException e){
             throw launderThrowable(e.getCause());
         }
   }
}

 

    在上个示例中，并行地执行两个不同类型的任务——下载图像与渲染页面。然而，通过对异构任务进行并行化来获得重大的性能提升是很困难的。因为，如果渲染文本的速度远远高于下载图像的速度，那么程序的最终性能与串行执行时的性能差别不大，而代码却变的更复杂了。

    只有当大量相互独立且同构的任务可以并发进行处理时，才能体现出将程序的工作负载分配到多个任务中带来的真正性能提升。

 

    3. 使用CompletionService,是页面元素在下载完成后立即显示出来。其中，图片是单个下载完成就立即显示。

       CompletionService将Executor和BlockingQueue的功能融合在一起。可以将Callable任务提交给它执行，然后使用类似于队列操作的take和poll等方法来获得已完成的结果，而这些结果会在完成时被封装为Future。ExecutorCompletionService实现了CompletionService，并将计算部分委托给一个Executor。

public class Renderere{
		private final ExecutorService executor;
		
		Renderer(ExecutorService executor)
		{
			this.executor = executor;
		}
		
		void renderPage(CharSequence source){
			List<ImageInfo> info = scanForImageInfo(source);
			CompletionService<ImageData> completionService = new ExecutorCompletionService<ImageData>(executor);
			for(final ImageInfo imageInfo : info){
				completionService.submit(new Callable<ImageData>() {
					public ImageData call(){
						return imageInfo.downloadImage();
					}
				});
			}
			renderText(source);
			
			try{
				for(int t=0, n=info.size(); t<n; t++){
					Future<ImageData> f = completionService.take();
					ImageData imageData = f.get();
					renderImage(imageData);
				}
			}catch(InterruptedException e){
				Thread.currentThread().interrupt();
			}catch(ExecutionException e){
				throw launderThrowable(e.getCause());
			}			
		}
	}