在Java Web应用程序中跟踪并发文件处理

Question

我有一个将任意PDF文件转换为图像的Java 1.5 Web应用程序。一次处理即使是单个PDF的所有页面也需要很长时间，因此我希望按需处理页面。

我已经read that I can use an ExecutorService在特定页面的HTTP请求到达时，在新线程中启动/排队图像生成操作。我如何确保不会在不使用单个线程执行程序的情况下对重复操作进行排队（例如，两个用户从同一PDF请求相同的页面）？我如何使用类似于同步列表的东西来跟踪工作线程正在处理哪些图像（或者什么类型的同步机制可以帮助我跟踪这些）？

Answer 1

您可以使用带有PDF标识符（例如文件路径左右）的ConcurrentHashMap<String, Future<String>>作为键和表示转换操作本身的任务作为值。

的ConcurrentHashMap的putIfAbsent方法可以处理比较并设置操作的问题和Future的isDone方法可以指示转换是否已经完成与否。

当putIfAbsent回报null，这意味着对于一个给定的PDF转换任务还不存在，所以你需要调用ExecutorService.submit(Callable<T> task)火了你的新创建的转换任务;否则，您可以省略此步骤并等待已有的任务完成。

样机：

Future<String> conversionTask = ... // blah 
Future<String> existingTask = conversions.putIfAbsent(pdfId, conversionTask); 
if (existingTask != null) { 
    conversionTask = existingTask; 
} 
// Either way, conversion is scheduled by now. 

的ExecutorService需要排队转换请求照顾。

转换完成后，您可以通过Future<V>.get()方法检索结果。

请注意，规范不允许在Java EE应用程序中产卵线程。一个常用的方法是将您的异步处理作为JMS服务分开 - Apache Camel可以帮助您在这里。

Answer 2

您可以使用ConcurrentSkipListSet或ConcurrentHashMap来跟踪哪些PDF已被处理（并且可能被缓存）或正在处理中。使用ConcurrentLinkedQueue来处理PDF到图像的请求;当工作线程将请求从队列中拉出时，它将其添加到Set/Map中，如果添加成功，则线程处理请求，如果添加失败，则请求已经在容器中。