{"id":3850,"date":"2025-07-12T12:53:25","date_gmt":"2025-07-12T04:53:25","guid":{"rendered":"https:\/\/www.laixuexila.com\/?p=3850"},"modified":"2025-07-12T12:53:25","modified_gmt":"2025-07-12T04:53:25","slug":"%e5%a6%82%e4%bd%95%e7%bb%93%e5%90%88-threadfactory%e3%80%81completionservice-%e5%81%9a%e4%bb%bb%e5%8a%a1%e5%88%86%e7%bb%84%e4%b8%8e%e7%9b%91%e6%8e%a7","status":"publish","type":"post","link":"https:\/\/www.laixuexila.com\/index.php\/2025\/07\/12\/%e5%a6%82%e4%bd%95%e7%bb%93%e5%90%88-threadfactory%e3%80%81completionservice-%e5%81%9a%e4%bb%bb%e5%8a%a1%e5%88%86%e7%bb%84%e4%b8%8e%e7%9b%91%e6%8e%a7\/","title":{"rendered":"\u5982\u4f55\u7ed3\u5408\u00a0ThreadFactory\u3001CompletionService\u00a0\u505a\u4efb\u52a1\u5206\u7ec4\u4e0e\u76d1\u63a7"},"content":{"rendered":"\n

\u7ed3\u5408 ThreadFactory<\/code> \u548c CompletionService<\/code>\uff0c\u4f60\u53ef\u4ee5\u4e3a\u7ebf\u7a0b\u6c60\u4efb\u52a1\u6267\u884c\u63d0\u4f9b\u66f4\u7cbe\u7ec6\u7684\u7ebf\u7a0b\u547d\u540d\u3001\u5206\u7ec4\u3001\u65e5\u5fd7\u8ffd\u8e2a\u3001\u7ed3\u679c\u6536\u96c6\u4e0e\u76d1\u63a7<\/strong>\u3002\u8fd9\u5728\u590d\u6742\u7cfb\u7edf\uff08\u5982\u5927\u89c4\u6a21\u5e76\u53d1\u4efb\u52a1\u8c03\u5ea6\u3001ETL\u3001Web \u722c\u866b\u3001\u591a\u79df\u6237\u4efb\u52a1\u5904\u7406\uff09\u4e2d\u975e\u5e38\u5b9e\u7528\u3002<\/p>\n\n\n\n

\n\n\n\n

\u4e00\u3001\u6838\u5fc3\u7ec4\u4ef6\u7b80\u4ecb<\/h2>\n\n\n\n
\u7ec4\u4ef6<\/th>\u4f5c\u7528<\/th><\/tr><\/thead>
ThreadFactory<\/code><\/td>\u81ea\u5b9a\u4e49\u7ebf\u7a0b\u521b\u5efa\u903b\u8f91\uff08\u5982\u547d\u540d\u3001\u8bbe\u7f6e\u5b88\u62a4\u7ebf\u7a0b\u3001\u5206\u7ec4\uff09<\/td><\/tr>
CompletionService<\/code><\/td>\u63d0\u4f9b\u4efb\u52a1\u6267\u884c\u540e\u7684\u7ed3\u679c\u4f18\u5148\u961f\u5217<\/strong>\uff0c\u53ef\u6309\u5b8c\u6210\u987a\u5e8f\u5904\u7406\u4efb\u52a1<\/strong><\/td><\/tr>
ExecutorService<\/code><\/td>\u5b9e\u9645\u6267\u884c\u4efb\u52a1<\/td><\/tr><\/tbody><\/table><\/figure>\n\n\n\n
\n\n\n\n

\u4e8c\u3001\u7ed3\u6784\u56fe\u7406\u89e3<\/h2>\n\n\n\n
+---------------------+\n| CustomThreadFactory |  \u2192 \u521b\u5efa\u7ebf\u7a0b\u5e76\u81ea\u5b9a\u4e49\u547d\u540d\u3001\u7ec4\n+---------------------+\n          \u2193\n+--------------------------+\n| ThreadPoolExecutor       |  \u2190 \u4f7f\u7528\u4e0a\u65b9\u5de5\u5382\u521b\u5efa\u7ebf\u7a0b\n+--------------------------+\n          \u2193 submit(task)\n+-----------------------------+\n| CompletionService           | \u2190 \u63d0\u4ea4\u4efb\u52a1\u3001\u7ed3\u679c\u6309\u5b8c\u6210\u987a\u5e8f\u53ef\u53d6\u51fa\n+-----------------------------+\n          \u2193 take()\n      Future<Result><\/code><\/pre>\n\n\n\n
\n\n\n\n
\u4e09\u3001\u5b8c\u6574\u5b9e\u6218\u793a\u4f8b\uff1a\u5206\u7ec4\u547d\u540d + CompletionService \u76d1\u63a7<\/h2>\n\n\n\n
1. \u81ea\u5b9a\u4e49\u7ebf\u7a0b\u5de5\u5382\uff08ThreadFactory\uff09<\/h3>\n\n\n\n
public class NamedThreadFactory implements ThreadFactory {\n    private final String groupName;\n    private final AtomicInteger threadNumber = new AtomicInteger(1);\n\n    public NamedThreadFactory(String groupName) {\n        this.groupName = groupName;\n    }\n\n    @Override\n    public Thread newThread(Runnable r) {\n        Thread t = new Thread(r);\n        t.setName(groupName + \"-thread-\" + threadNumber.getAndIncrement());\n        return t;\n    }\n}<\/code><\/pre>\n\n\n\n
\n\n\n\n
2. \u4f7f\u7528 CompletionService \u63d0\u4ea4\u4efb\u52a1\u5e76\u76d1\u63a7\u7ed3\u679c<\/h3>\n\n\n\n
public class CompletionServiceExample {\n    public static void main(String[] args) throws Exception {\n        \/\/ \u7ebf\u7a0b\u6c60 + \u81ea\u5b9a\u4e49\u7ebf\u7a0b\u5de5\u5382\n        ExecutorService executor = Executors.newFixedThreadPool(\n            4, new NamedThreadFactory(\"fetcher\")\n        );\n\n        \/\/ \u7ed3\u5408 CompletionService\uff1a\u7ed3\u679c\u961f\u5217\u6309\u5b8c\u6210\u987a\u5e8f\n        CompletionService<String> cs = new ExecutorCompletionService<>(executor);\n\n        \/\/ \u63d0\u4ea4\u4efb\u52a1\uff08\u6a21\u62df\u8017\u65f6\u4e0d\u540c\u7684\u4efb\u52a1\uff09\n        for (int i = 1; i <= 5; i++) {\n            final int taskId = i;\n            cs.submit(() -> {\n                long sleep = (long)(Math.random() * 3000);\n                Thread.sleep(sleep);\n                return Thread.currentThread().getName() + \" \u5b8c\u6210\u4efb\u52a1 #\" + taskId + \" \u7528\u65f6\uff1a\" + sleep + \"ms\";\n            });\n        }\n\n        \/\/ \u76d1\u63a7\u6267\u884c\u7ed3\u679c\uff08\u6309\u5b8c\u6210\u987a\u5e8f\uff09\n        for (int i = 0; i < 5; i++) {\n            Future<String> result = cs.take(); \/\/ \u963b\u585e\u76f4\u5230\u6709\u4efb\u52a1\u5b8c\u6210\n            System.out.println(\"\u2705 \u5df2\u5b8c\u6210\u4efb\u52a1\uff1a\" + result.get());\n        }\n\n        executor.shutdown();\n    }\n}<\/code><\/pre>\n\n\n\n
\n\n\n\n
\u56db\u3001\u8fdb\u9636\u529f\u80fd\u5efa\u8bae\uff08\u4efb\u52a1\u5206\u7ec4 + \u591a\u79df\u6237\u573a\u666f\uff09<\/h2>\n\n\n\n
\u4f60\u53ef\u4ee5\u7528\u591a\u4e2a\u7ebf\u7a0b\u6c60+CompletionService\u5206\u522b\u5904\u7406\u4e0d\u540c\u4e1a\u52a1\uff1a<\/p>\n\n\n\n
Map<String, ExecutorService> tenantPools = new HashMap<>();\nMap<String, CompletionService<?>> tenantCompletions = new HashMap<>();\n\nfor (String tenantId : tenantList) {\n    ThreadFactory factory = new NamedThreadFactory(\"tenant-\" + tenantId);\n    ExecutorService pool = Executors.newFixedThreadPool(3, factory);\n    tenantPools.put(tenantId, pool);\n    tenantCompletions.put(tenantId, new ExecutorCompletionService<>(pool));\n}<\/code><\/pre>\n\n\n\n
\u8fd9\u6837\u5c31\u53ef\u4ee5\u4e3a\u6bcf\u4e2a\u79df\u6237\u9694\u79bb\u4efb\u52a1\u7ebf\u7a0b\u548c\u7ed3\u679c\u6536\u96c6\u961f\u5217\uff0c\u589e\u5f3a\u53ef\u89c2\u5bdf\u6027\u4e0e\u8c03\u5ea6\u7075\u6d3b\u6027\u3002<\/p>\n\n\n\n
\n\n\n\n
\u4e94\u3001\u5982\u4f55\u505a\u4efb\u52a1\u76d1\u63a7\uff08\u8017\u65f6 \/ \u5f02\u5e38 \/ \u8ffd\u8e2a\uff09<\/h2>\n\n\n\n
\u4f60\u53ef\u4ee5\u5c01\u88c5\u4e00\u4e2a\u4efb\u52a1\u5305\u88c5\u5668\uff0c\u7528\u4e8e\u7edf\u4e00\u65e5\u5fd7\u8bb0\u5f55\u3001\u5f02\u5e38\u6355\u83b7\u3001\u8017\u65f6\u5206\u6790\uff1a<\/p>\n\n\n\n
class MonitoredTask<V> implements Callable<V> {\n    private final Callable<V> task;\n    private final String taskName;\n\n    public MonitoredTask(Callable<V> task, String taskName) {\n        this.task = task;\n        this.taskName = taskName;\n    }\n\n    @Override\n    public V call() throws Exception {\n        long start = System.currentTimeMillis();\n        try {\n            V result = task.call();\n            long time = System.currentTimeMillis() - start;\n            System.out.println(\"\u2705 [\" + taskName + \"] \u6267\u884c\u5b8c\u6210\uff0c\u8017\u65f6\uff1a\" + time + \"ms\");\n            return result;\n        } catch (Exception ex) {\n            System.err.println(\"\u274c [\" + taskName + \"] \u6267\u884c\u5931\u8d25\uff1a\" + ex.getMessage());\n            throw ex;\n        }\n    }\n}<\/code><\/pre>\n\n\n\n
\u4f7f\u7528\u65f6\u5305\u4e00\u5c42\uff1a<\/p>\n\n\n\n
cs.submit(new MonitoredTask<>(() -> doBusinessLogic(), \"task-42\"));<\/code><\/pre>\n\n\n\n
\n\n\n\n
\u516d\u3001\u76d1\u63a7\u5efa\u8bae\uff08\u751f\u4ea7\u573a\u666f\uff09<\/h2>\n\n\n\n
\u76d1\u63a7\u7ef4\u5ea6<\/th>\u65b9\u6848<\/th><\/tr><\/thead>
\u7ebf\u7a0b\u540d\u79f0 \/ \u6765\u6e90<\/td>\u4f7f\u7528 ThreadFactory<\/code> \u547d\u540d<\/td><\/tr>
\u4efb\u52a1\u5b8c\u6210\u8017\u65f6<\/td>\u5305\u88c5\u4efb\u52a1 \/ System.nanoTime()<\/code><\/td><\/tr>
\u5f02\u5e38\u6536\u96c6<\/td>\u5305\u88c5\u4efb\u52a1\u5185\u90e8 try-catch \u65e5\u5fd7\u8bb0\u5f55<\/td><\/tr>
\u4efb\u52a1\u5b8c\u6210\u6570\u91cf<\/td>AtomicInteger<\/code> \u6216 cs.take()<\/code> \u8ba1\u6570<\/td><\/tr>
\u72b6\u6001\u66b4\u9732<\/td>\u96c6\u6210\u5230 Actuator \/ Prometheus Exporter<\/td><\/tr><\/tbody><\/table><\/figure>\n\n\n\n
\n\n\n\n
\u5b98\u65b9\u6587\u6863\u4e0e\u94fe\u63a5<\/h2>\n\n\n\n