問題描述

我也是剛用上Java8的Stream，所有的一切都還在照貓畫虎的階段。

在異常處理這塊不敢貿(mào)然前進(jìn)，因?yàn)槲铱吹侥称牡倪@樣一段話

在單線程環(huán)境中，使用捕獲受檢異常并重新拋出非受檢異常的方法是可行的。但是在多線程環(huán)境這樣用，就存在一些風(fēng)險(xiǎn)。

多線程環(huán)境中，Lambda表達(dá)式中發(fā)生的錯(cuò)誤會(huì)被自動(dòng)傳遞到主線程中。這會(huì)帶來兩個(gè)問題：

這不會(huì)停止其他正在并行執(zhí)行的Lambda表達(dá)式。如果有多個(gè)線程拋出了異常，在主線程中卻只能捕獲到一個(gè)線程中的異常。如果這些異常信息都很重要的話，那么更好的方法是在Lambda表達(dá)式中就進(jìn)行異常處理并將異常信息作為結(jié)果的一部分返回到主線程中。

我現(xiàn)在是用的Stream流的Map方法，當(dāng)然用的是并發(fā)，想在map里的方法里只要有一個(gè)出錯(cuò)就讓他停下來，不運(yùn)行其他的。。這個(gè)需求該怎么搞。。

paths.stream() .map(path -> {try { return new File(path).getCanonicalPath();} catch(IOException ex) { throw new RuntimeException(ex);} }) .forEach(System.out::println);

我用了這種方法確實(shí)停下來了，那還有什么好的方法，或者說是否有何問題，這樣的話就拿不到具體哪個(gè)線程有問題了吧

問題解答

你的思維模式就不對(duì)，map filter 這類不是語(yǔ)法糖， java8還是有函數(shù)式編程能力的。函數(shù)式的核心是不變性，這里不是要求取消變量，而是要建立一種等價(jià)思維，以求值 > 過程的方式去思考問題。

你的例子，比如要求在map中停下來這就在設(shè)計(jì)之外，因?yàn)閙ap的語(yǔ)意保證了它一定會(huì)遍歷完所有數(shù)據(jù)，返回的類型一定一致，而且長(zhǎng)度相同。同樣貿(mào)然拋出rumtime exception也是非常的不優(yōu)雅。

有幾個(gè)方案，使用optional或者either（這個(gè)官方不提供，需要自己弄一個(gè)）來包裝你的返回類型來保證map語(yǔ)義（把錯(cuò)誤放到返回值里去，但是類型不變，具體可以百度）

如果你的數(shù)據(jù)有前后關(guān)系，使用fold（reduce）來處理而不是map。

不使用stream而用回for break，編程其實(shí)就是編程，關(guān)鍵是解決問題，針對(duì)問題來選擇最好的方案，有的時(shí)候steam方案不如傳統(tǒng)的for，fork/join也不如手工sync notify。

另，stream的并行其實(shí)沒有你想的那么好，濫用了copyonwrite，我自己玩過一陣之后幾乎再也不用了。不過 java8有個(gè)completableFuture估計(jì)能滿足你的要求。

CountDownLatch(1)

catch異常時(shí)：

CountDownLatch.countDown();

最后：

CountDownLatch.await();xxx.stop();

Java8的Stream沒用過了。。。