\u6709\u4eba\u66fe\u7ecf\u8bf4\u8fc7\uff08\u5f88\u62b1\u6b49\uff0c\u6211\u4eec\u627e\u4e0d\u5230\u539f\u53e5\u4e86\uff09\uff1a<\/p>\n
\u521d\u7ea7\u7a0b\u5e8f\u5458\u8ba4\u4e3a\u5e76\u53d1\u5f88\u96be\u3002
\n\u4e2d\u7ea7\u7a0b\u5e8f\u5458\u8ba4\u4e3a\u5e76\u53d1\u5f88\u7b80\u5355\u3002
\n\u9ad8\u7ea7\u7a0b\u5e8f\u5458\u8ba4\u4e3a\u5e76\u53d1\u5f88\u96be\u3002
\n\u8fd9\u8bf4\u7684\u5f88\u5bf9\u3002\u4f46\u662f\u4ece\u597d\u7684\u65b9\u9762\u6765\u770b\uff0cJava8\u4e3a\u6211\u4eec\u5e26\u6765\u4e86\u8f6c\u673a\uff0c\u901a\u8fc7lambda\u8868\u8fbe\u5f0f\u548c\u6539\u8fdb\u7684API\u53ef\u4ee5\u4f7f\u5f97\u7f16\u5199\u5e76\u53d1\u4ee3\u7801\u66f4\u5bb9\u6613\u3002\u8ba9\u6211\u4eec\u6765\u5177\u4f53\u7684\u770b\u770bJava8\u7684\u6539\u8fdb\u5427\uff1a<\/p>\n
Java8\u5bf9JDK 1.0 API\u7684\u6539\u8fdb<\/p>\n
java.lang.Thread\u65e9\u5728JDK 1.0\u7248\u672c\u4e2d\u5c31\u5df2\u7ecf\u5b58\u5728\u3002\u5728java8\u4e2d\u88ab\u6ce8\u89e3\u4e3a\u529f\u80fd\u6027\u63a5\u53e3\u7684java.lang.Runnable\u4e5f\u662f\u3002<\/p>\n
\u4ece\u73b0\u5728\u8d77\uff0c\u51e0\u4e4e\u4e0d\u9700\u8981\u52a8\u5927\u8111\u6211\u4eec\u5c31\u53ef\u4ee5\u63d0\u4ea4Runnables\u7ed9\u4e00\u4e2a\u7ebf\u7a0b\u3002\u8ba9\u6211\u4eec\u5047\u8bbe\u6211\u4eec\u6709\u4e00\u4e2a\u5f88\u8017\u65f6\u7684\u64cd\u4f5c\uff1a<\/p>\n
public static int longOperation() {
\n System.out.println(“Running on thread #”
\n + Thread.currentThread().getId());<\/p>\n
\/\/ […]
\n return 42;
\n}
\n\u6211\u4eec\u53ef\u4ee5\u7528\u591a\u79cd\u65b9\u6cd5\u628a\u8fd9\u4e2a\u64cd\u4f5c\u4f20\u9012\u7ed9\u7ebf\u7a0b\uff0c\u4f8b\u5982\uff1a<\/p>\n
Thread[] threads = {<\/p>\n
\/\/ Pass a lambda to a thread
\n new Thread(() -> {
\n longOperation();
\n }),<\/p>\n
\/\/ Pass a method reference to a thread
\n new Thread(ThreadGoodies::longOperation)
\n};<\/p>\n
\/\/ Start all threads
\nArrays.stream(threads).forEach(Thread::start);<\/p>\n
\/\/ Join all threads
\nArrays.stream(threads).forEach(t -> {
\n try { t.join(); }
\n catch (InterruptedException ignore) {}
\n});
\n\u5c31\u50cf\u6211\u4eec\u5728\u4e4b\u524d\u7684\u535a\u6587\u91cc\u63d0\u5230\u7684\u4e00\u6837\uff0clambda\u8868\u8fbe\u5f0f\u6ca1\u6709\u4e00\u4e2a\u7b80\u6d01\u7684\u65b9\u5f0f\u6765\u5904\u7406\u88ab\u68c0\u67e5\u5f02\u5e38\u5b9e\u5728\u662f\u4e00\u5927\u61be\u4e8b\u3002\u5728java.util.function\u5305\u4e2d\u65b0\u589e\u7684\u529f\u80fd\u6027\u63a5\u53e3\u90fd\u4e0d\u4f1a\u629b\u51fa\u88ab\u68c0\u67e5\u5f02\u5e38\uff0c\u628a\u8fd9\u9879\u5de5\u4f5c\u7559\u7ed9\u4e86\u8c03\u7528\u7aef\u3002<\/p>\n
\u5728\u4e0a\u4e00\u7bc7\u535a\u6587\u4e2d\uff0c\u6211\u4eec\u5df2\u7ecf\u56e0\u6b64\u800c\u53d1\u5e03\u4e86jOO\u03bb(also jOOL\uff0cjOO-Lambda)\u5305,\u8be5\u5305\u5305\u88c5\u4e86JDK\u4e2d\u7684\u6bcf\u4e00\u4e2a\u529f\u80fd\u6027\u63a5\u53e3\uff0c\u5177\u6709\u76f8\u540c\u529f\u80fd\u800c\u4e14\u4e5f\u5141\u8bb8\u629b\u51fa\u88ab\u68c0\u5f02\u5e38\u3002\u8fd9\u5728\u4f7f\u7528\u8001\u7684JDK API\u65f6\u7279\u522b\u6709\u7528\uff0c\u4f8b\u5982JDBC\uff0c\u6216\u8005\u4e0a\u9762\u63d0\u5230\u7684Thread API\u3002\u4f7f\u7528jOO\u03bb\uff0c\u6211\u4eec\u53ef\u4ee5\u8fd9\u4e48\u5199\uff1a<\/p>\n
\/\/ Join all threads
\nArrays.stream(threads).forEach(Unchecked.consumer(
\n t -> t.join()
\n));
\nJava8\u4e2d\u6539\u8fdb\u7684Java5 API<\/p>\n
Java\u7684\u591a\u7ebf\u7a0b\u529f\u80fd\u4e00\u76f4\u6ca1\u6709\u4ec0\u4e48\u8d77\u8272\uff0c\u76f4\u5230Java5\u7684ExecutorService\u7684\u53d1\u5e03\u3002\u7ba1\u7406\u591a\u7ebf\u7a0b\u662f\u4e00\u4e2a\u8d1f\u62c5\uff0c\u4eba\u4eec\u9700\u8981\u989d\u5916\u7684\u5e93\u6216\u8005\u4e00\u4e2aJ2EE\/JEE\u5bb9\u5668\u6765\u7ba1\u7406\u7ebf\u7a0b\u6c60\u3002\u8fd9\u4e9b\u7528Java5\u6765\u5904\u7406\u5df2\u7ecf\u5bb9\u6613\u4e86\u5f88\u591a\u3002\u6211\u4eec\u73b0\u5728\u53ef\u4ee5\u63d0\u4ea4\u4e00\u4e2aRunnable\u5bf9\u8c61\u6216\u8005\u4e00\u4e2aCallable\u5bf9\u8c61\u5230ExcutorService\uff0c\u5b83\u7ba1\u7406\u81ea\u5df1\u7684\u7ebf\u7a0b\u6c60\u3002<\/p>\n
\u4e0b\u9762\u662f\u4e00\u4e2a\u6211\u4eec\u5982\u4f55\u5728Java8\u4e2d\u5229\u7528\u8fd9\u4e9bJava5\u7684\u5e76\u53d1API\u7684\u4f8b\u5b50\uff1a<\/p>\n
ExecutorService service = Executors
\n .newFixedThreadPool(5);<\/p>\n
Future[] answers = {
\n service.submit(() -> longOperation()),
\n service.submit(ThreadGoodies::longOperation)
\n};<\/p>\n
Arrays.stream(answers).forEach(Unchecked.consumer(
\n f -> System.out.println(f.get())
\n));
\n\u6ce8\u610f\u770b\uff0c\u6211\u4eec\u662f\u5982\u4f55\u518d\u6b21\u4f7f\u7528jOO\u03bb\u4e2d\u7684UncheckedConsumer\u6765\u5305\u88c5\u5728\u8fd0\u884c\u671f\u8c03\u7528get()\u65b9\u6cd5\u629b\u51fa\u7684\u88ab\u68c0\u5f02\u5e38\u3002<\/p>\n
Java8\u4e2d\u7684\u5e76\u884c\u548cForkJoinPool<\/p>\n
\u73b0\u5728\uff0cJava8\u7684Streams API\u5728\u5e76\u53d1\u548c\u5e76\u884c\u65b9\u9762\u6709\u4e86\u5f88\u5927\u6539\u8fdb\u3002
\n\u5728Java8\u4e2d\u4f60\u53ef\u4ee5\u5199\u51fa\u5982\u4e0b\u7684\u4ee3\u7801\uff1a<\/p>\n
Arrays.stream(new int[]{ 1, 2, 3, 4, 5, 6 })
\n .parallel()
\n .max()
\n .ifPresent(System.out::println);
\n\u867d\u7136\u5728\u8fd9\u4e2a\u7279\u6b8a\u7684\u4f8b\u5b50\u4e2d\u4e0d\u662f\u5f88\u5fc5\u8981\uff0c\u4f46\u8fd8\u662f\u633a\u6709\u610f\u601d\u7684\uff0c\u4f60\u4ec5\u4ec5\u8c03\u7528\u4e86parallel()\u5c31\u8fd0\u884cIntStream.max()\u6765\u542f\u7528ForkJoinPool\uff0c\u800c\u4f60\u4e0d\u5fc5\u62c5\u5fc3\u5305\u542b\u7684ForkJoinTasks\u3002\u8fd9\u662f\u975e\u5e38\u6709\u7528\u7684\uff0c\u56e0\u4e3a\u4e0d\u662f\u6bcf\u4e2a\u4eba\u90fd\u80fd\u591f\u63a5\u53d7JDK7\u4e2d\u5f15\u8fdb\u7684\u590d\u6742\u7684JorkJoin API\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6709\u4eba\u66fe\u7ecf\u8bf4\u8fc7\uff08\u5f88\u62b1\u6b49\uff0c\u6211\u4eec\u627e\u4e0d\u5230\u539f\u53e5\u4e86\uff09\uff1a \u521d\u7ea7\u7a0b\u5e8f\u5458\u8ba4\u4e3a\u5e76\u53d1\u5f88\u96be\u3002 \u4e2d\u7ea7\u7a0b\u5e8f\u5458 …<\/p>\n