Java 8 通用线程池工具类:异步任务执行利器
下面是一个简单的 Java 8 线程池工具类,用于执行异步任务:\n\njava\nimport java.util.concurrent.ExecutorService;\nimport java.util.concurrent.Executors;\nimport java.util.function.Consumer;\n\npublic class ThreadPoolUtils {\n private static ExecutorService executorService;\n\n public static void execute(Runnable task) {\n if (executorService == null) {\n executorService = Executors.newCachedThreadPool();\n }\n executorService.execute(task);\n }\n\n public static <T> void executeAsync(T input, Consumer<T> task) {\n execute(() -> task.accept(input));\n }\n\n public static void shutdown() {\n if (executorService != null) {\n executorService.shutdown();\n }\n }\n}\n\n\n使用示例:\n\njava\npublic class Main {\n public static void main(String[] args) {\n ThreadPoolUtils.execute(() -> {\n // 执行异步任务\n System.out.println("异步任务1");\n });\n\n ThreadPoolUtils.executeAsync("Hello", input -> {\n // 执行异步任务,并传递参数\n System.out.println("异步任务2,参数:" + input);\n });\n\n ThreadPoolUtils.shutdown();\n }\n}\n\n\n在上面的示例中,execute方法用于执行一个普通的异步任务,executeAsync方法用于执行一个带有参数的异步任务。可以根据实际需求自行调整线程池的初始化方式,这里使用了Executors.newCachedThreadPool()创建一个缓存线程池。在任务执行完毕后,可以调用shutdown方法来关闭线程池。
原文地址: https://www.cveoy.top/t/topic/p253 著作权归作者所有。请勿转载和采集!