活动介绍
file-type

Java并发编程:理解Executor、Executors与ExecutorService

版权申诉

DOCX文件

39KB | 更新于2024-08-08 | 13 浏览量 | 0 下载量 举报 收藏
download 限时特惠:#14.90
"本文档主要探讨Java并发编程中的Executor、Executors和ExecutorService的概念及其使用。Executor是一个接口,用于执行Runnable任务,而ExecutorService是Executor的一个子接口,提供了更多的生命周期管理和任务跟踪功能。" 在Java并发编程中,Executor框架是一个重要的工具,它简化了线程管理和任务调度。Executor接口定义了一个单一的方法`execute(Runnable command)`,用于执行给定的Runnable任务。这个方法的引入避免了程序员需要直接创建和管理线程,而是将线程的创建和管理交给了Executor,提高了代码的可维护性和灵活性。 ExecutorService是Executor接口的一个扩展,它提供了一系列额外的方法来控制Executor的生命周期和管理任务的执行状态。例如,`shutdown()`方法允许平滑地关闭ExecutorService,不再接受新的任务,并等待已提交任务的完成。这种方式确保正在执行的任务能够正常结束,而不会被突然中断。`isDone()`方法可以用来检查Future任务是否已经完成,`get()`方法用于获取任务的执行结果,如果任务尚未完成,`get()`会阻塞直到结果可用。此外,`submit()`方法用于提交任务并返回一个Future,这样可以追踪任务的状态,甚至在必要时取消任务。 ExecutorService还支持Callable任务,Callable任务与Runnable类似,但可以返回一个结果。通过`submit(Callable<T> task)`方法提交Callable任务,返回的Future对象可以使用`get()`方法获取计算结果。如果需要取消任务,可以调用Future的`cancel(boolean mayInterruptIfRunning)`方法,参数表示是否允许立即中断任务。 在实际开发中,通常使用Executors类来创建ExecutorService实例。Executors提供了多种工厂方法,如`newFixedThreadPool(int nThreads)`创建固定大小的线程池,`newSingleThreadExecutor()`创建只有一个线程的线程池,`newCachedThreadPool()`创建一个缓存线程池,它会根据需要创建新线程,而当线程空闲时间过长则会被回收。 总结来说,Executor和ExecutorService是Java并发编程的核心组件,它们为开发者提供了方便的方式来组织并发任务,管理线程池,以及控制任务的执行流程。通过使用这些工具,开发者可以更加专注于业务逻辑,而不是底层的线程管理,从而提高代码的可读性和可维护性。

相关推荐

filetype

@SneakyThrows public List<File> wordToPdf(List<String> fileUrl,IConverter converter){ log.info("---------------------word转pdf--开始--------------------------"); List<File> pdfFiles = new ArrayList<>(); ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * 2); // 调整池大小以适应需求 List<Future<File>> futures = new ArrayList<>(); for (String url : fileUrl) { futures.add(executorService.submit(() -> { int index = 0; if (url.endsWith(".docx")) { index = url.lastIndexOf(".docx"); } else { index = url.lastIndexOf(".doc"); } String outFilePath = url.substring(0, index);; // 获取输出文件路径 return wordToPdf(url, outFilePath, converter); })); } for (Future<File> future : futures) { try { pdfFiles.add(future.get()); // 收集结果, 阻塞直到任务完成 } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } } executorService.shutdown(); log.info("---------------------word转pdf--结束--------------------------"); return pdfFiles; } @SneakyThrows public File wordToPdf(String filePath, String outFilePath,IConverter converter) { try(InputStream doc=new URL(filePath).openStream();) { File outputFile=File.createTempFile(outFilePath, ".pdf"); OutputStream outputStream = new FileOutputStream(outputFile); //转换docx=>pdf converter.convert(doc).as(DocumentType.DOCX).to(outputStream).as(DocumentType.PDF).execute(); doc.close(); outputStream.close(); return outputFile; } catch (Exception e) { e.printStackTrace(); }响应速度还是很慢,在这个代码基础上优化代码,生成完整的优化后的代码

filetype

@SneakyThrows public List<File> wordToPdf(List<String> fileUrl,IConverter converter){ log.info("---------------------word转pdf--开始--------------------------"); List<File> pdfFiles = new ArrayList<>(); ExecutorService executorService = Executors.newFixedThreadPool(4); // 调整池大小以适应需求 List<Future<File>> futures = new ArrayList<>(); for (String url : fileUrl) { futures.add(executorService.submit(() -> { int index = 0; if (url.endsWith(".docx")) { index = url.lastIndexOf(".docx"); } else { index = url.lastIndexOf(".doc"); } String outFilePath = url.substring(0, index);; // 获取输出文件路径 return wordToPdf(url, outFilePath, converter); })); } for (Future<File> future : futures) { try { pdfFiles.add(future.get()); // 收集结果, 阻塞直到任务完成 } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } } executorService.shutdown(); log.info("---------------------word转pdf--结束--------------------------"); return pdfFiles; } /** * word转pdf * @param filePath * @param outFilePath */ @SneakyThrows public File wordToPdf(String filePath, String outFilePath,IConverter converter) { try(InputStream doc=new URL(filePath).openStream();) { File outputFile=File.createTempFile(outFilePath, ".pdf"); OutputStream outputStream = new FileOutputStream(outputFile); //转换docx=>pdf converter.convert(doc).as(DocumentType.DOCX).to(outputStream).as(DocumentType.PDF).execute(); doc.close(); outputStream.close(); return outputFile; } catch (Exception e) { e.printStackTrace(); } return null; }这个方法运行速度还是很慢