Java8Stream異常處理
問(wèn)題描述
我也是剛用上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ì)帶來(lái)兩個(gè)問(wèn)題:
這不會(huì)停止其他正在并行執(zhí)行的Lambda表達(dá)式。如果有多個(gè)線程拋出了異常,在主線程中卻只能捕獲到一個(gè)線程中的異常。如果這些異常信息都很重要的話,那么更好的方法是在Lambda表達(dá)式中就進(jìn)行異常處理并將異常信息作為結(jié)果的一部分返回到主線程中。
我現(xiàn)在是用的Stream流的Map方法,當(dāng)然用的是并發(fā),想在map里的方法里只要有一個(gè)出錯(cuò)就讓他停下來(lái),不運(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í)停下來(lái)了,那還有什么好的方法,或者說(shuō)是否有何問(wèn)題,這樣的話就拿不到具體哪個(gè)線程有問(wèn)題了吧
問(wèn)題解答
回答1:你的思維模式就不對(duì),map filter 這類不是語(yǔ)法糖, java8還是有函數(shù)式編程能力的。函數(shù)式的核心是不變性,這里不是要求取消變量,而是要建立一種等價(jià)思維,以求值 > 過(guò)程的方式去思考問(wèn)題。
你的例子,比如要求在map中停下來(lái)這就在設(shè)計(jì)之外,因?yàn)閙ap的語(yǔ)意保證了它一定會(huì)遍歷完所有數(shù)據(jù),返回的類型一定一致,而且長(zhǎng)度相同。同樣貿(mào)然拋出rumtime exception也是非常的不優(yōu)雅。
有幾個(gè)方案,使用optional或者either(這個(gè)官方不提供,需要自己弄一個(gè))來(lái)包裝你的返回類型來(lái)保證map語(yǔ)義(把錯(cuò)誤放到返回值里去,但是類型不變,具體可以百度)
如果你的數(shù)據(jù)有前后關(guān)系,使用fold(reduce)來(lái)處理而不是map。
不使用stream而用回for break,編程其實(shí)就是編程,關(guān)鍵是解決問(wèn)題,針對(duì)問(wèn)題來(lái)選擇最好的方案,有的時(shí)候steam方案不如傳統(tǒng)的for,fork/join也不如手工sync notify。
另,stream的并行其實(shí)沒(méi)有你想的那么好,濫用了copyonwrite,我自己玩過(guò)一陣之后幾乎再也不用了。不過(guò) java8有個(gè)completableFuture估計(jì)能滿足你的要求。
回答2:CountDownLatch(1)
catch異常時(shí):
CountDownLatch.countDown();
最后:
CountDownLatch.await();xxx.stop();
Java8的Stream沒(méi)用過(guò)了。。。
相關(guān)文章:
1. Docker for Mac 創(chuàng)建的dnsmasq容器連不上/不工作的問(wèn)題2. docker安裝后出現(xiàn)Cannot connect to the Docker daemon.3. PHP求助,求幫忙謝謝各位4. extra沒(méi)有加載出來(lái)5. Span標(biāo)簽6. django進(jìn)行數(shù)據(jù)庫(kù)的查詢7. python - linux怎么在每天的凌晨2點(diǎn)執(zhí)行一次這個(gè)log.py文件8. mysql - 為什么where條件中or加索引不起作用?9. ios - 類似微博首頁(yè),一張圖的時(shí)候是如何確定圖大小的?10. javascript - 天貓首頁(yè)首屏數(shù)據(jù)來(lái)源
