java jsr

Java 7最有趣的改進(jìn)之一是對(duì)并發(fā)的更好支持。 借助JSR 166并發(fā)實(shí)用程序，我們獲得了一些非常有用的并發(fā)改進(jìn)。 在我看來(lái)，fork-join庫(kù)在軟件工程中具有很高的實(shí)際應(yīng)用潛力。 Fork and join為算法提供了非常簡(jiǎn)單的編程模型，可以將其實(shí)現(xiàn)為遞歸任務(wù)。 有很多算法可以使用分治法來(lái)實(shí)現(xiàn)。

在未來(lái)幾年中，我們將看到標(biāo)準(zhǔn)臺(tái)式機(jī)，筆記本電腦和服務(wù)器計(jì)算機(jī)中的內(nèi)核數(shù)量將不斷增加。 原因很簡(jiǎn)單：添加額外的內(nèi)核要比構(gòu)建更快的單個(gè)處理器便宜。 因此，我們將不得不編寫更多支持并發(fā)的軟件以利用更好的硬件。

老實(shí)說(shuō)，我不喜歡并發(fā)。 我的個(gè)人規(guī)則是“您需要一個(gè)充分的理由來(lái)實(shí)現(xiàn)并發(fā)，并且如果需要做的話必須非常小心。”在過(guò)去的幾年中，我看到的錯(cuò)誤實(shí)現(xiàn)多于工作。 這就是為什么我喜歡fork＆join庫(kù)的原因。 清晰的編程模型可實(shí)現(xiàn)樣板代碼，可防止您出錯(cuò)。 但是，如果您打算使用fork和join，請(qǐng)花一些時(shí)間來(lái)了解其行為。

文件＃1和＃2中的示例與Java 7文檔中的示例代碼非常相似。 通常，使用遞歸算法的斐波那契數(shù)不是一個(gè)好主意，因?yàn)榇嬖诟玫木€性解決方案（請(qǐng)比較http://nayuki.eigenstate.org/page/fast-fibonacci-algorithms ），但它更易于實(shí)現(xiàn)和理解相對(duì)于其它的。 因此，讓我們看一下示例：

// File #1: FibonacciTask.java [error handling, parameter validation and asserts removed] package com.sprunck.sample;import java.util.concurrent.RecursiveTask;public class FibonacciTask extends RecursiveTask<Long> {private static final long serialVersionUID = 1L;private final long inputValue;public FibonacciTask(long inputValue) {this.inputValue = inputValue;}@Overridepublic Long compute() {if (inputValue == 0L) {return 0L;} else if (inputValue <= 2L) {return 1L;} else {final FibonacciTask firstWorker = new FibonacciTask(inputValue - 1L);firstWorker.fork();final FibonacciTask secondWorker = new FibonacciTask(inputValue - 2L);return secondWorker.compute() + firstWorker.join();}} }// File #2: FibonacciTaskTest.java package com.sprunck.sample;import java.util.concurrent.ForkJoinPool; import junit.framework.Assert; import org.junit.Test;public class FibonacciTaskTest {// it makes no sense to create more threads than available cores (no speed improvement here)private static final int AVAILABLE_PROCESSORS = Runtime.getRuntime().availableProcessors();// create thread poolprivate final ForkJoinPool pool = new ForkJoinPool(AVAILABLE_PROCESSORS);@Testpublic void testFibonacciArray() {// more test data: http://www.maths.surrey.ac.uk/hosted-sites/R.Knott/Fibonacci/fibtable.htmllong results[] = { 0L, 1L, 1L, 2L, 3L, 5L, 8L, 13L, 21L, 34L, 55L, 89L, 144L, 233L, 377L, 610L, 987L, 1597L,2584L, 4181L, 6765L };for (int inputValue = 0; inputValue < results.length; inputValue++) {final FibonacciTask task = new FibonacciTask(inputValue);System.out.print("Fibonacci(" + inputValue + ") = ");final long result = pool.invoke(task);System.out.println(result);Assert.assertEquals(results[inputValue], result);}} }

// FibonacciTaskTest.java的輸出

Fibonacci(0) = 0 Fibonacci(1) = 1 Fibonacci(2) = 1 Fibonacci(3) = 2 Fibonacci(4) = 3 Fibonacci(5) = 5 Fibonacci(6) = 8 Fibonacci(7) = 13 Fibonacci(8) = 21 Fibonacci(9) = 34 Fibonacci(10) = 55 Fibonacci(11) = 89 Fibonacci(12) = 144 Fibonacci(13) = 233 Fibonacci(14) = 377 Fibonacci(15) = 610 Fibonacci(16) = 987 Fibonacci(17) = 1597 Fibonacci(18) = 2584 Fibonacci(19) = 4181 Fibonacci(20) = 6765

到目前為止，這是一個(gè)簡(jiǎn)單明了的解決方案。 沒(méi)有用于并行的樣板代碼，例如線程同步。

但我想鼓勵(lì)您更深入地了解解決方案中發(fā)生的情況。 在文件＃3和＃4中，您可以找到同一程序的增強(qiáng)版本。 第一個(gè)版本和第二個(gè)版本之間的唯一區(qū)別是，一些代碼可以跟蹤執(zhí)行過(guò)程中發(fā)生的事情，而較小的slowTask（）可以模擬更實(shí)際的行為。

// File #3: FibonacciTaskTraces.java package com.sprunck.sample;import java.util.concurrent.RecursiveTask;public class FibonacciTaskTraces extends RecursiveTask<Long> {private static final long serialVersionUID = 1L;// just needed to format debug outputpublic static final String OUTPUT_PREFIX = " | ";private final String prefix;private final long inputValue;public FibonacciTaskTraces(long inputValue, final String prefix) {this.inputValue = inputValue;this.prefix = prefix;}@Overridepublic Long compute() {if (inputValue == 0L) {slowTask();return 0L;} else if (inputValue <= 2L) {slowTask();return 1L;} else {final long firstValue = inputValue - 1L;System.out.println(prefix + " - Fibonacci(" + firstValue + ") <- " + Thread.currentThread().getName()+ " (fork) ");final FibonacciTaskTraces firstWorker = new FibonacciTaskTraces(firstValue, prefix + OUTPUT_PREFIX);firstWorker.fork();final long secondValue = inputValue - 2L;System.out.println(prefix + " - Fibonacci(" + secondValue + ") <- " + Thread.currentThread().getName());final FibonacciTaskTraces secondWorker = new FibonacciTaskTraces(secondValue, prefix + OUTPUT_PREFIX);long result = secondWorker.compute() + firstWorker.join();System.out.println(prefix + " - Fibonacci(" + inputValue + ") = " + result + " <- "+ Thread.currentThread().getName() + " (join)");slowTask();return result;}}/** just simulate a longer running task (with out disturbing the other threads) */private void slowTask() {for (int k = 0, i = 0; i < 1000 * 1000 * 100; i++) {i = i + k;}} }// File #4: FibonacciTaskTracesTask.javapackage com.sprunck.sample;import java.util.concurrent.ForkJoinPool; import junit.framework.Assert; import org.junit.Test;public class FibonacciTaskTracesTest {// it makes no sense to create more threads than available cores (no speed improvement here)private static final int AVAILABLE_PROCESSORS = Runtime.getRuntime().availableProcessors();// create thread poolprivate final ForkJoinPool pool = new ForkJoinPool(AVAILABLE_PROCESSORS);@Testpublic void testFibonacciArrayTraces() {// more test data: http://www.maths.surrey.ac.uk/hosted-sites/R.Knott/Fibonacci/fibtable.htmllong results[] = { 0L, 1L, 1L, 2L, 3L, 5L, 8L, 13L };for (int inputValue = 0; inputValue < results.length; inputValue++) {final FibonacciTaskTraces task = new FibonacciTaskTraces(inputValue, " | ");System.out.println("invoke Fibonacci(" + inputValue + ") <- " + Thread.currentThread().getName());final long result = pool.invoke(task);System.out.println("result = " + result + "\n");Assert.assertEquals(results[inputValue], result);}} }

// FibonacciTaskTracesTest.java的輸出

invoke Fibonacci(0) <- mainresult = 0invoke Fibonacci(1) <- mainresult = 1invoke Fibonacci(2) <- mainresult = 1invoke Fibonacci(3) <- main| - Fibonacci(2) <- ForkJoinPool-1-worker-1 (fork) | - Fibonacci(1) <- ForkJoinPool-1-worker-1| - Fibonacci(3) = 2 <- ForkJoinPool-1-worker-1 (join)result = 2invoke Fibonacci(4) <- main| - Fibonacci(3) <- ForkJoinPool-1-worker-1 (fork) | - Fibonacci(2) <- ForkJoinPool-1-worker-1| | - Fibonacci(2) <- ForkJoinPool-1-worker-2 (fork) | | - Fibonacci(1) <- ForkJoinPool-1-worker-2| | - Fibonacci(3) = 2 <- ForkJoinPool-1-worker-2 (join)| - Fibonacci(4) = 3 <- ForkJoinPool-1-worker-1 (join)result = 3invoke Fibonacci(5) <- main| - Fibonacci(4) <- ForkJoinPool-1-worker-1 (fork) | - Fibonacci(3) <- ForkJoinPool-1-worker-1| | - Fibonacci(2) <- ForkJoinPool-1-worker-1 (fork) | | - Fibonacci(1) <- ForkJoinPool-1-worker-1| | - Fibonacci(3) <- ForkJoinPool-1-worker-2 (fork) | | - Fibonacci(2) <- ForkJoinPool-1-worker-2| | | - Fibonacci(2) <- ForkJoinPool-1-worker-2 (fork) | | | - Fibonacci(1) <- ForkJoinPool-1-worker-2| | - Fibonacci(3) = 2 <- ForkJoinPool-1-worker-1 (join)| | | - Fibonacci(3) = 2 <- ForkJoinPool-1-worker-2 (join)| | - Fibonacci(4) = 3 <- ForkJoinPool-1-worker-2 (join)| - Fibonacci(5) = 5 <- ForkJoinPool-1-worker-1 (join)result = 5invoke Fibonacci(6) <- main| - Fibonacci(5) <- ForkJoinPool-1-worker-1 (fork) | - Fibonacci(4) <- ForkJoinPool-1-worker-1| | - Fibonacci(3) <- ForkJoinPool-1-worker-1 (fork) | | - Fibonacci(2) <- ForkJoinPool-1-worker-1| | - Fibonacci(4) <- ForkJoinPool-1-worker-2 (fork) | | - Fibonacci(3) <- ForkJoinPool-1-worker-2| | | - Fibonacci(2) <- ForkJoinPool-1-worker-2 (fork) | | | - Fibonacci(1) <- ForkJoinPool-1-worker-2| | | - Fibonacci(2) <- ForkJoinPool-1-worker-1 (fork) | | | - Fibonacci(1) <- ForkJoinPool-1-worker-1| | | - Fibonacci(3) = 2 <- ForkJoinPool-1-worker-2 (join)| | | - Fibonacci(3) = 2 <- ForkJoinPool-1-worker-1 (join)| | | - Fibonacci(3) <- ForkJoinPool-1-worker-2 (fork) | | | - Fibonacci(2) <- ForkJoinPool-1-worker-2| | - Fibonacci(4) = 3 <- ForkJoinPool-1-worker-1 (join)| | | | - Fibonacci(2) <- ForkJoinPool-1-worker-2 (fork) | | | | - Fibonacci(1) <- ForkJoinPool-1-worker-2| | | | - Fibonacci(3) = 2 <- ForkJoinPool-1-worker-2 (join)| | | - Fibonacci(4) = 3 <- ForkJoinPool-1-worker-2 (join)| | - Fibonacci(5) = 5 <- ForkJoinPool-1-worker-2 (join)| - Fibonacci(6) = 8 <- ForkJoinPool-1-worker-1 (join)result = 8invoke Fibonacci(7) <- main| - Fibonacci(6) <- ForkJoinPool-1-worker-1 (fork) | - Fibonacci(5) <- ForkJoinPool-1-worker-1| | - Fibonacci(4) <- ForkJoinPool-1-worker-1 (fork) | | - Fibonacci(3) <- ForkJoinPool-1-worker-1| | | - Fibonacci(2) <- ForkJoinPool-1-worker-1 (fork) | | | - Fibonacci(1) <- ForkJoinPool-1-worker-1| | - Fibonacci(5) <- ForkJoinPool-1-worker-2 (fork) | | - Fibonacci(4) <- ForkJoinPool-1-worker-2| | | - Fibonacci(3) <- ForkJoinPool-1-worker-2 (fork) | | | - Fibonacci(2) <- ForkJoinPool-1-worker-2| | | | - Fibonacci(2) <- ForkJoinPool-1-worker-2 (fork) | | | | - Fibonacci(1) <- ForkJoinPool-1-worker-2| | | - Fibonacci(3) = 2 <- ForkJoinPool-1-worker-1 (join)| | | - Fibonacci(3) <- ForkJoinPool-1-worker-1 (fork) | | | - Fibonacci(2) <- ForkJoinPool-1-worker-1| | | | - Fibonacci(3) = 2 <- ForkJoinPool-1-worker-2 (join)| | | | - Fibonacci(2) <- ForkJoinPool-1-worker-1 (fork) | | | | - Fibonacci(1) <- ForkJoinPool-1-worker-1| | | - Fibonacci(4) = 3 <- ForkJoinPool-1-worker-2 (join)| | | - Fibonacci(4) <- ForkJoinPool-1-worker-2 (fork) | | | - Fibonacci(3) <- ForkJoinPool-1-worker-2| | | | - Fibonacci(2) <- ForkJoinPool-1-worker-2 (fork) | | | | - Fibonacci(1) <- ForkJoinPool-1-worker-2| | | | - Fibonacci(3) = 2 <- ForkJoinPool-1-worker-1 (join)| | | - Fibonacci(4) = 3 <- ForkJoinPool-1-worker-1 (join)| | | | - Fibonacci(3) = 2 <- ForkJoinPool-1-worker-2 (join)| | - Fibonacci(5) = 5 <- ForkJoinPool-1-worker-1 (join)| | | | - Fibonacci(3) <- ForkJoinPool-1-worker-2 (fork) | | | | - Fibonacci(2) <- ForkJoinPool-1-worker-2| | | | | - Fibonacci(2) <- ForkJoinPool-1-worker-1 (fork) | | | | | - Fibonacci(1) <- ForkJoinPool-1-worker-1| | | | | - Fibonacci(3) = 2 <- ForkJoinPool-1-worker-1 (join)| | | | - Fibonacci(4) = 3 <- ForkJoinPool-1-worker-2 (join)| | | - Fibonacci(5) = 5 <- ForkJoinPool-1-worker-2 (join)| | - Fibonacci(6) = 8 <- ForkJoinPool-1-worker-2 (join)| - Fibonacci(7) = 13 <- ForkJoinPool-1-worker-1 (join)result = 13

現(xiàn)在，輸出使您可以更深入地了解程序的處理。 出現(xiàn)以下斐波納契數(shù)計(jì)算方法：

• 前三個(gè)斐波那契數(shù)在主線程中處理，
• 下一個(gè)斐波那契數(shù)僅在一個(gè)新線程（ForkJoinPool-1-worker-1）中處理，并且
• 從第五個(gè)斐波納契數(shù)開(kāi)始，使用了兩個(gè)線程（ForkJoinPool-1-worker-1和ForkJoinPool-1-worker-2）。

該算法效率低下，因?yàn)樵谔幚碇写嬖诤芏嗳哂嗖僮?#xff08;重新計(jì)算相同的斐波那契數(shù)）。 在現(xiàn)實(shí)生活中的應(yīng)用中，您應(yīng)該小心使用這種效率低下的算法。 一些痕跡有助于了解發(fā)生了什么。

推薦品

使用fork和join既簡(jiǎn)單又直接，但是要花一些時(shí)間來(lái)跟蹤和理解您的實(shí)現(xiàn)。

有時(shí)實(shí)現(xiàn)同一算法的兩個(gè)版本（一個(gè)用于分析，另一個(gè)用于生產(chǎn)）會(huì)有所幫助。

花一些時(shí)間來(lái)設(shè)計(jì)和理解更好的并發(fā)算法是一項(xiàng)不錯(cuò)的投資。

以此方式開(kāi)發(fā)了概率計(jì)算器 （ 概率計(jì)算器演示– PCALC ）。

參考： 如何在Java 7 – JSR 166并發(fā)實(shí)用程序中實(shí)現(xiàn)fork and join？ 由我們的JCG合作伙伴 Markus Sprunck在Software Engineering Candies博客上獲得。

翻譯自: https://www.javacodegeeks.com/2012/04/fork-and-join-in-java-7-jsr-166.html

java jsr

總結(jié)

以上是生活随笔為你收集整理的java jsr_分叉并加入Java 7 – JSR 166并发实用程序的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。