20個(gè)使用 Java CompletableFuture的例子

作者：鳥窩
原文鏈接：
https://colobu.com/2018/03/12/20-Examples-of-Using-Java%E2%80%99s-CompletableFuture/

這篇文章介紹 Java 8 的 CompletionStage API和它的標(biāo)準(zhǔn)庫的實(shí)現(xiàn) CompletableFuture笋粟。API通過例子的方式演示了它的行為虚婿，每個(gè)例子演示一到兩個(gè)行為羽资。

既然CompletableFuture類實(shí)現(xiàn)了CompletionStage接口，首先我們需要理解這個(gè)接口的契約。它代表了一個(gè)特定的計(jì)算的階段蹈集，可以同步或者異步的被完成。你可以把它看成一個(gè)計(jì)算流水線上的一個(gè)單元，最終會(huì)產(chǎn)生一個(gè)最終結(jié)果佩捞，這意味著幾個(gè)CompletionStage可以串聯(lián)起來，一個(gè)完成的階段可以觸發(fā)下一階段的執(zhí)行蕾哟，接著觸發(fā)下一次一忱，接著……

除了實(shí)現(xiàn)CompletionStage接口， CompletableFuture也實(shí)現(xiàn)了future接口, 代表一個(gè)未完成的異步事件谭确。CompletableFuture提供了方法帘营，能夠顯式地完成這個(gè)future,所以它叫CompletableFuture。

1逐哈、 創(chuàng)建一個(gè)完成的CompletableFuture

最簡單的例子就是使用一個(gè)預(yù)定義的結(jié)果創(chuàng)建一個(gè)完成的CompletableFuture,通常我們會(huì)在計(jì)算的開始階段使用它芬迄。

static void completedFutureExample() {
CompletableFuture cf = CompletableFuture.completedFuture("message");
assertTrue(cf.isDone());
assertEquals("message", cf.getNow(null));
}
getNow(null)方法在future完成的情況下會(huì)返回結(jié)果，就比如上面這個(gè)例子昂秃，否則返回null (傳入的參數(shù))禀梳。

2、運(yùn)行一個(gè)簡單的異步階段

這個(gè)例子創(chuàng)建一個(gè)一個(gè)異步執(zhí)行的階段：

static void runAsyncExample() {
CompletableFuture cf = CompletableFuture.runAsync(() -> {
assertTrue(Thread.currentThread().isDaemon());
randomSleep();
});
assertFalse(cf.isDone());
sleepEnough();
assertTrue(cf.isDone());
}
通過這個(gè)例子可以學(xué)到兩件事情：

CompletableFuture的方法如果以Async結(jié)尾肠骆，它會(huì)異步的執(zhí)行(沒有指定executor的情況下)算途， 異步執(zhí)行通過ForkJoinPool實(shí)現(xiàn)， 它使用守護(hù)線程去執(zhí)行任務(wù)蚀腿。注意這是CompletableFuture的特性嘴瓤， 其它CompletionStage可以override這個(gè)默認(rèn)的行為。

3唯咬、在前一個(gè)階段上應(yīng)用函數(shù)

下面這個(gè)例子使用前面 #1 的完成的CompletableFuture纱注， #1返回結(jié)果為字符串message,然后應(yīng)用一個(gè)函數(shù)把它變成大寫字母。

static void thenApplyExample() {
CompletableFuture cf = CompletableFuture.completedFuture("message").thenApply(s -> {
assertFalse(Thread.currentThread().isDaemon());
return s.toUpperCase();
});
assertEquals("MESSAGE", cf.getNow(null));
}
注意thenApply方法名稱代表的行為胆胰。

then意味著這個(gè)階段的動(dòng)作發(fā)生當(dāng)前的階段正常完成之后狞贱。本例中，當(dāng)前節(jié)點(diǎn)完成蜀涨，返回字符串message瞎嬉。

Apply意味著返回的階段將會(huì)對(duì)結(jié)果前一階段的結(jié)果應(yīng)用一個(gè)函數(shù)。

函數(shù)的執(zhí)行會(huì)被阻塞厚柳，這意味著getNow()只有打斜操作被完成后才返回氧枣。

4、在前一個(gè)階段上異步應(yīng)用函數(shù)

通過調(diào)用異步方法(方法后邊加Async后綴)别垮，串聯(lián)起來的CompletableFuture可以異步地執(zhí)行（使用ForkJoinPool.commonPool()）便监。

static void thenApplyAsyncExample() {
CompletableFuture cf = CompletableFuture.completedFuture("message").thenApplyAsync(s -> {
assertTrue(Thread.currentThread().isDaemon());
randomSleep();
return s.toUpperCase();
});
assertNull(cf.getNow(null));
assertEquals("MESSAGE", cf.join());
}
5、使用定制的Executor在前一個(gè)階段上異步應(yīng)用函數(shù)

異步方法一個(gè)非常有用的特性就是能夠提供一個(gè)Executor來異步地執(zhí)行CompletableFuture。這個(gè)例子演示了如何使用一個(gè)固定大小的線程池來應(yīng)用大寫函數(shù)烧董。

static ExecutorService executor = Executors.newFixedThreadPool(3, new ThreadFactory() {
int count = 1;

@Override
public Thread newThread(Runnable runnable) {
    return new Thread(runnable, "custom-executor-" + count++);
}

});

static void thenApplyAsyncWithExecutorExample() {
CompletableFuture cf = CompletableFuture.completedFuture("message").thenApplyAsync(s -> {
assertTrue(Thread.currentThread().getName().startsWith("custom-executor-"));
assertFalse(Thread.currentThread().isDaemon());
randomSleep();
return s.toUpperCase();
}, executor);

assertNull(cf.getNow(null));
assertEquals("MESSAGE", cf.join());

}
6毁靶、消費(fèi)前一階段的結(jié)果

如果下一階段接收了當(dāng)前階段的結(jié)果，但是在計(jì)算的時(shí)候不需要返回值(它的返回類型是void)逊移， 那么它可以不應(yīng)用一個(gè)函數(shù)预吆，而是一個(gè)消費(fèi)者， 調(diào)用方法也變成了thenAccept:

static void thenAcceptExample() {
StringBuilder result = new StringBuilder();
CompletableFuture.completedFuture("thenAccept message")
.thenAccept(s -> result.append(s));
assertTrue("Result was empty", result.length() > 0);
}
本例中消費(fèi)者同步地執(zhí)行胳泉，所以我們不需要在CompletableFuture調(diào)用join方法拐叉。

7、異步地消費(fèi)遷移階段的結(jié)果

同樣扇商，可以使用thenAcceptAsync方法凤瘦， 串聯(lián)的CompletableFuture可以異步地執(zhí)行。

static void thenAcceptAsyncExample() {
StringBuilder result = new StringBuilder();
CompletableFuture cf = CompletableFuture.completedFuture("thenAcceptAsync message")
.thenAcceptAsync(s -> result.append(s));
cf.join();
assertTrue("Result was empty", result.length() > 0);
}
8钳吟、完成計(jì)算異常

現(xiàn)在我們來看一下異步操作如何顯式地返回異常廷粒，用來指示計(jì)算失敗。我們簡化這個(gè)例子红且，操作處理一個(gè)字符串坝茎，把它轉(zhuǎn)換成答謝，我們模擬延遲一秒暇番。

我們使用thenApplyAsync(Function, Executor)方法嗤放，第一個(gè)參數(shù)傳入大寫函數(shù)， executor是一個(gè)delayed executor,在執(zhí)行前會(huì)延遲一秒壁酬。

static void completeExceptionallyExample() {
CompletableFuture cf = CompletableFuture.completedFuture("message").thenApplyAsync(String::toUpperCase,
CompletableFuture.delayedExecutor(1, TimeUnit.SECONDS));
CompletableFuture exceptionHandler = cf.handle((s, th) -> { return (th != null) ? "message upon cancel" : ""; });
cf.completeExceptionally(new RuntimeException("completed exceptionally"));
assertTrue("Was not completed exceptionally", cf.isCompletedExceptionally());
try {
cf.join();
fail("Should have thrown an exception");
} catch(CompletionException ex) { // just for testing
assertEquals("completed exceptionally", ex.getCause().getMessage());
}

assertEquals("message upon cancel", exceptionHandler.join());

}
讓我們看一下細(xì)節(jié)次酌。

首先我們創(chuàng)建了一個(gè)CompletableFuture, 完成后返回一個(gè)字符串message,接著我們調(diào)用thenApplyAsync方法，它返回一個(gè)CompletableFuture舆乔。這個(gè)方法在第一個(gè)函數(shù)完成后岳服，異步地應(yīng)用轉(zhuǎn)大寫字母函數(shù)。

這個(gè)例子還演示了如何通過delayedExecutor(timeout, timeUnit)延遲執(zhí)行一個(gè)異步任務(wù)希俩。

我們創(chuàng)建了一個(gè)分離的handler階段：exceptionHandler吊宋， 它處理異常異常，在異常情況下返回message upon cancel颜武。

下一步我們顯式地用異常完成第二個(gè)階段璃搜。在階段上調(diào)用join方法，它會(huì)執(zhí)行大寫轉(zhuǎn)換鳞上，然后拋出CompletionException（正常的join會(huì)等待1秒这吻，然后得到大寫的字符串。不過我們的例子還沒等它執(zhí)行就完成了異常）篙议， 然后它觸發(fā)了handler階段唾糯。

9、取消計(jì)算

和完成異常類似，我們可以調(diào)用cancel(boolean mayInterruptIfRunning)取消計(jì)算移怯。對(duì)于CompletableFuture類拒名，布爾參數(shù)并沒有被使用，這是因?yàn)樗]有使用中斷去取消操作芋酌，相反，cancel等價(jià)于completeExceptionally(new CancellationException())雁佳。

static void cancelExample() {
CompletableFuture cf = CompletableFuture.completedFuture("message").thenApplyAsync(String::toUpperCase,
CompletableFuture.delayedExecutor(1, TimeUnit.SECONDS));
CompletableFuture cf2 = cf.exceptionally(throwable -> "canceled message");
assertTrue("Was not canceled", cf.cancel(true));
assertTrue("Was not completed exceptionally", cf.isCompletedExceptionally());
assertEquals("canceled message", cf2.join());
}
10脐帝、在兩個(gè)完成的階段其中之一上應(yīng)用函數(shù)

下面的例子創(chuàng)建了CompletableFuture, applyToEither處理兩個(gè)階段， 在其中之一上應(yīng)用函數(shù)(包保證哪一個(gè)被執(zhí)行)糖权。本例中的兩個(gè)階段一個(gè)是應(yīng)用大寫轉(zhuǎn)換在原始的字符串上堵腹， 另一個(gè)階段是應(yīng)用小些轉(zhuǎn)換。

static void applyToEitherExample() {
String original = "Message";
CompletableFuture cf1 = CompletableFuture.completedFuture(original)
.thenApplyAsync(s -> delayedUpperCase(s));
CompletableFuture cf2 = cf1.applyToEither(
CompletableFuture.completedFuture(original).thenApplyAsync(s -> delayedLowerCase(s)),
s -> s + " from applyToEither");
assertTrue(cf2.join().endsWith(" from applyToEither"));
}
11星澳、在兩個(gè)完成的階段其中之一上調(diào)用消費(fèi)函數(shù)

和前一個(gè)例子很類似了疚顷，只不過我們調(diào)用的是消費(fèi)者函數(shù) (Function變成Consumer):

static void acceptEitherExample() {
String original = "Message";
StringBuilder result = new StringBuilder();
CompletableFuture cf = CompletableFuture.completedFuture(original)
.thenApplyAsync(s -> delayedUpperCase(s))
.acceptEither(CompletableFuture.completedFuture(original).thenApplyAsync(s -> delayedLowerCase(s)),
s -> result.append(s).append("acceptEither"));
cf.join();
assertTrue("Result was empty", result.toString().endsWith("acceptEither"));
}
12、在兩個(gè)階段都執(zhí)行完后運(yùn)行一個(gè) Runnable

這個(gè)例子演示了依賴的CompletableFuture如果等待兩個(gè)階段完成后執(zhí)行了一個(gè)Runnable禁偎。注意下面所有的階段都是同步執(zhí)行的腿堤，第一個(gè)階段執(zhí)行大寫轉(zhuǎn)換，第二個(gè)階段執(zhí)行小寫轉(zhuǎn)換如暖。

static void runAfterBothExample() {
String original = "Message";
StringBuilder result = new StringBuilder();
CompletableFuture.completedFuture(original).thenApply(String::toUpperCase).runAfterBoth(
CompletableFuture.completedFuture(original).thenApply(String::toLowerCase),
() -> result.append("done"));
assertTrue("Result was empty", result.length() > 0);
}
13笆檀、 使用BiConsumer處理兩個(gè)階段的結(jié)果

上面的例子還可以通過BiConsumer來實(shí)現(xiàn):

static void thenAcceptBothExample() {
String original = "Message";
StringBuilder result = new StringBuilder();
CompletableFuture.completedFuture(original).thenApply(String::toUpperCase).thenAcceptBoth(
CompletableFuture.completedFuture(original).thenApply(String::toLowerCase),
(s1, s2) -> result.append(s1 + s2));
assertEquals("MESSAGEmessage", result.toString());
}
14、使用BiFunction處理兩個(gè)階段的結(jié)果

如果CompletableFuture依賴兩個(gè)前面階段的結(jié)果盒至， 它復(fù)合兩個(gè)階段的結(jié)果再返回一個(gè)結(jié)果酗洒，我們就可以使用thenCombine()函數(shù)。整個(gè)流水線是同步的枷遂，所以getNow()會(huì)得到最終的結(jié)果樱衷，它把大寫和小寫字符串連接起來。

static void thenCombineExample() {
String original = "Message";
CompletableFuture cf = CompletableFuture.completedFuture(original).thenApply(s -> delayedUpperCase(s))
.thenCombine(CompletableFuture.completedFuture(original).thenApply(s -> delayedLowerCase(s)),
(s1, s2) -> s1 + s2);
assertEquals("MESSAGEmessage", cf.getNow(null));
}
15酒唉、異步使用BiFunction處理兩個(gè)階段的結(jié)果

類似上面的例子矩桂，但是有一點(diǎn)不同：依賴的前兩個(gè)階段異步地執(zhí)行，所以thenCombine()也異步地執(zhí)行黔州，即時(shí)它沒有Async后綴耍鬓。

Javadoc中有注釋：

Actions supplied for dependent completions of non-async methods may be performed by the thread that completes the current CompletableFuture, or by any other caller of a completion method

所以我們需要join方法等待結(jié)果的完成。

static void thenCombineAsyncExample() {
String original = "Message";
CompletableFuture cf = CompletableFuture.completedFuture(original)
.thenApplyAsync(s -> delayedUpperCase(s))
.thenCombine(CompletableFuture.completedFuture(original).thenApplyAsync(s -> delayedLowerCase(s)),
(s1, s2) -> s1 + s2);
assertEquals("MESSAGEmessage", cf.join());
}
16流妻、組合 CompletableFuture

我們可以使用thenCompose()完成上面兩個(gè)例子牲蜀。這個(gè)方法等待第一個(gè)階段的完成(大寫轉(zhuǎn)換)， 它的結(jié)果傳給一個(gè)指定的返回CompletableFuture函數(shù)绅这，它的結(jié)果就是返回的CompletableFuture的結(jié)果涣达。

有點(diǎn)拗口，但是我們看例子來理解。函數(shù)需要一個(gè)大寫字符串做參數(shù)度苔，然后返回一個(gè)CompletableFuture, 這個(gè)CompletableFuture會(huì)轉(zhuǎn)換字符串變成小寫然后連接在大寫字符串的后面匆篓。

static void thenComposeExample() {
String original = "Message";
CompletableFuture cf = CompletableFuture.completedFuture(original).thenApply(s -> delayedUpperCase(s))
.thenCompose(upper -> CompletableFuture.completedFuture(original).thenApply(s -> delayedLowerCase(s))
.thenApply(s -> upper + s));
assertEquals("MESSAGEmessage", cf.join());
}
17、當(dāng)幾個(gè)階段中的一個(gè)完成寇窑，創(chuàng)建一個(gè)完成的階段

下面的例子演示了當(dāng)任意一個(gè)CompletableFuture完成后鸦概， 創(chuàng)建一個(gè)完成的CompletableFuture.

待處理的階段首先創(chuàng)建， 每個(gè)階段都是轉(zhuǎn)換一個(gè)字符串為大寫甩骏。因?yàn)楸纠羞@些階段都是同步地執(zhí)行(thenApply), 從anyOf中創(chuàng)建的CompletableFuture會(huì)立即完成窗市，這樣所有的階段都已完成，我們使用whenComplete(BiConsumer<? super Object, ? super Throwable> action)處理完成的結(jié)果饮笛。

static void anyOfExample() {
StringBuilder result = new StringBuilder();
List messages = Arrays.asList("a", "b", "c");
List<CompletableFuture> futures = messages.stream()
.map(msg -> CompletableFuture.completedFuture(msg).thenApply(s -> delayedUpperCase(s)))
.collect(Collectors.toList());
CompletableFuture.anyOf(futures.toArray(new CompletableFuture[futures.size()])).whenComplete((res, th) -> {
if(th == null) {
assertTrue(isUpperCase((String) res));
result.append(res);
}
});
assertTrue("Result was empty", result.length() > 0);
}
18咨察、當(dāng)所有的階段都完成后創(chuàng)建一個(gè)階段

上一個(gè)例子是當(dāng)任意一個(gè)階段完成后接著處理，接下來的兩個(gè)例子演示當(dāng)所有的階段完成后才繼續(xù)處理, 同步地方式和異步地方式兩種福青。

static void allOfExample() {
StringBuilder result = new StringBuilder();
List messages = Arrays.asList("a", "b", "c");
List<CompletableFuture> futures = messages.stream()
.map(msg -> CompletableFuture.completedFuture(msg).thenApply(s -> delayedUpperCase(s)))
.collect(Collectors.toList());
CompletableFuture.allOf(futures.toArray(new CompletableFuture[futures.size()])).whenComplete((v, th) -> {
futures.forEach(cf -> assertTrue(isUpperCase(cf.getNow(null))));
result.append("done");
});
assertTrue("Result was empty", result.length() > 0);
}
19摄狱、當(dāng)所有的階段都完成后異步地創(chuàng)建一個(gè)階段

使用thenApplyAsync()替換那些單個(gè)的CompletableFutures的方法，allOf()會(huì)在通用池中的線程中異步地執(zhí)行无午。所以我們需要調(diào)用join方法等待它完成媒役。

static void allOfAsyncExample() {
StringBuilder result = new StringBuilder();
List messages = Arrays.asList("a", "b", "c");
List<CompletableFuture> futures = messages.stream()
.map(msg -> CompletableFuture.completedFuture(msg).thenApplyAsync(s -> delayedUpperCase(s)))
.collect(Collectors.toList());
CompletableFuture allOf = CompletableFuture.allOf(futures.toArray(new CompletableFuture[futures.size()]))
.whenComplete((v, th) -> {
futures.forEach(cf -> assertTrue(isUpperCase(cf.getNow(null))));
result.append("done");
});
allOf.join();
assertTrue("Result was empty", result.length() > 0);
}
20、真實(shí)的例子

Now that the functionality of CompletionStage and specifically CompletableFuture is explored, the below example applies them in a practical scenario:

現(xiàn)在你已經(jīng)了解了CompletionStage 和 CompletableFuture 的一些函數(shù)的功能宪迟，下面的例子是一個(gè)實(shí)踐場景：

首先異步調(diào)用cars方法獲得Car的列表刊愚，它返回CompletionStage場景。cars消費(fèi)一個(gè)遠(yuǎn)程的REST API踩验。
然后我們復(fù)合一個(gè)CompletionStage填寫每個(gè)汽車的評(píng)分鸥诽，通過rating(manufacturerId)返回一個(gè)CompletionStage, 它會(huì)異步地獲取汽車的評(píng)分(可能又是一個(gè)REST API調(diào)用)
當(dāng)所有的汽車填好評(píng)分后，我們結(jié)束這個(gè)列表箕憾，所以我們調(diào)用allOf得到最終的階段牡借， 它在前面階段所有階段完成后才完成。
在最終的階段調(diào)用whenComplete(),我們打印出每個(gè)汽車和它的評(píng)分袭异。
cars().thenCompose(cars -> {
List<CompletionStage> updatedCars = cars.stream()
.map(car -> rating(car.manufacturerId).thenApply(r -> {
car.setRating(r);
return car;
})).collect(Collectors.toList());

CompletableFuture done = CompletableFuture
        .allOf(updatedCars.toArray(new CompletableFuture[updatedCars.size()]));
return done.thenApply(v -> updatedCars.stream().map(CompletionStage::toCompletableFuture)
        .map(CompletableFuture::join).collect(Collectors.toList()));

}).whenComplete((cars, th) -> {
if (th == null) {
cars.forEach(System.out::println);
} else {
throw new RuntimeException(th);
}
}).toCompletableFuture().join();
因?yàn)槊總€(gè)汽車的實(shí)例都是獨(dú)立的钠龙，得到每個(gè)汽車的評(píng)分都可以異步地執(zhí)行，這會(huì)提高系統(tǒng)的性能(延遲)御铃，而且碴里，等待所有的汽車評(píng)分被處理使用的是allOf方法，而不是手工的線程等待(Thread#join() 或 a CountDownLatch)上真。

這些例子可以幫助你更好的理解相關(guān)的API,你可以在github上得到所有的例子的代碼咬腋。
其它參考文檔

Reactive programming with Java 8 and simple-react : The Tutorial
CompletableFuture Overview
CompletableFuture vs Future: going async with Java 8 new features
spotify/completable-futures

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 人面猴
    序言：七十年代末，一起剝皮案震驚了整個(gè)濱河市睡互，隨后出現(xiàn)的幾起案子根竿，更是在濱河造成了極大的恐慌陵像，老刑警劉巖，帶你破解...
    沈念sama閱讀 217,509評(píng)論 6贊 504
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件寇壳，死亡現(xiàn)場離奇詭異醒颖，居然都是意外死亡，警方通過查閱死者的電腦和手機(jī)壳炎，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,806評(píng)論 3贊 394
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進(jìn)店門泞歉，熙熙樓的掌柜王于貴愁眉苦臉地迎上來，“玉大人匿辩，你說我怎么就攤上這事疏日。” “怎么了撒汉？”我有些...
    開封第一講書人閱讀 163,875評(píng)論 0贊 354
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵，是天一觀的道長涕滋。 經(jīng)常有香客問我睬辐，道長，這世上最難降的妖魔是什么宾肺？ 我笑而不...
    開封第一講書人閱讀 58,441評(píng)論 1贊 293
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任溯饵，我火速辦了婚禮，結(jié)果婚禮上锨用，老公的妹妹穿的比我還像新娘丰刊。我一直安慰自己，他們只是感情好增拥，可當(dāng)我...
    茶點(diǎn)故事閱讀 67,488評(píng)論 6贊 392
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布啄巧。 她就那樣靜靜地躺著，像睡著了一般掌栅。 火紅的嫁衣襯著肌膚如雪秩仆。 梳的紋絲不亂的頭發(fā)上，一...
    開封第一講書人閱讀 51,365評(píng)論 1贊 302
  • 城市分裂傳說
    那天猾封，我揣著相機(jī)與錄音澄耍，去河邊找鬼。 笑死晌缘，一個(gè)胖子當(dāng)著我的面吹牛齐莲，可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播磷箕，決...
    沈念sama閱讀 40,190評(píng)論 3贊 418
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼选酗，長吁一口氣：“原來是場噩夢(mèng)啊……” “哼！你這毒婦竟也來了岳枷？” 一聲冷哼從身側(cè)響起星掰，我...
    開封第一講書人閱讀 39,062評(píng)論 0贊 276
  • 萬榮殺人案實(shí)錄
    序言：老撾萬榮一對(duì)情侶失蹤多望，失蹤者是張志新（化名）和其女友劉穎，沒想到半個(gè)月后氢烘，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體怀偷，經(jīng)...
    沈念sama閱讀 45,500評(píng)論 1贊 314
  • ?護(hù)林員之死
    正文 獨(dú)居荒郊野嶺守林人離奇死亡，尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,706評(píng)論 3贊 335
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年播玖，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了椎工。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,834評(píng)論 1贊 347
  • 活死人
    序言：一個(gè)原本活蹦亂跳的男人離奇死亡蜀踏，死狀恐怖维蒙，靈堂內(nèi)的尸體忽然破棺而出，到底是詐尸還是另有隱情果覆，我是刑警寧澤颅痊，帶...
    沈念sama閱讀 35,559評(píng)論 5贊 345
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布，位于F島的核電站局待，受9級(jí)特大地震影響斑响，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜钳榨，卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,167評(píng)論 3贊 328
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一舰罚、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧薛耻，春花似錦营罢、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,779評(píng)論 0贊 22
  • 一樁弒父案饲漾，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至缕溉，卻和暖如春能颁，著一層夾襖步出監(jiān)牢的瞬間，已是汗流浹背倒淫。 一陣腳步聲響...
    開封第一講書人閱讀 32,912評(píng)論 1贊 269
  • 情欲美人皮
    我被黑心中介騙來泰國打工伙菊， 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留，地道東北人敌土。 一個(gè)月前我還...
    沈念sama閱讀 47,958評(píng)論 2贊 370
  • 代替公主和親
    正文 我出身青樓镜硕，卻偏偏與公主長得像，于是被迫代替她去往敵國和親返干。 傳聞我的和親對(duì)象是個(gè)殘疾皇子兴枯，可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,779評(píng)論 2贊 354