服務(wù)器中如何使用特定的執(zhí)行程序來(lái)阻止操作

這篇文章將為大家詳細(xì)講解有關(guān)服務(wù)器中如何使用特定的執(zhí)行程序來(lái)阻止操作，小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

使用特定的執(zhí)行程序來(lái)阻止操作

因?yàn)橐粋€(gè)緩慢的操作而使整個(gè)服務(wù)器變得無(wú)響應(yīng)，這通常不是開(kāi)發(fā)人員想要的。不幸的是，對(duì)于RPC，響應(yīng)時(shí)間通常是不可預(yù)測(cè)的。

假設(shè)服務(wù)器有100個(gè)工作線程，有一個(gè)端點(diǎn)，稱為100 RPS。在內(nèi)部，它發(fā)出一個(gè)RPC調(diào)用，通常需要10毫秒。在某個(gè)時(shí)間點(diǎn)，此RPC的響應(yīng)時(shí)間變?yōu)?秒，在峰值期間服務(wù)器能夠做的惟一的一件事就是等待這些調(diào)用，而其他端點(diǎn)則無(wú)法訪問(wèn)。

@GET
@Path("/genre/{name}")
@Produces(MediaType.APPLICATION_JSON)
public Response getGenre(@PathParam("name") String genreName) {
	Genre genre = potentiallyVerySlowSynchronousCall(genreName);
	return Response.ok(genre).build();
}

解決這個(gè)問(wèn)題最簡(jiǎn)單的方法是提交代碼，它將阻塞調(diào)用變成一個(gè)線程池：

@GET
@Path("/genre/{name}")
@Produces(MediaType.APPLICATION_JSON)
public void getGenre(@PathParam("name") String genreName, @Suspended AsyncResponse response) {
	response.setTimeout(1L, TimeUnit.SECONDS);
	executorService.submit(() -> {
		Genre genre = potentiallyVerySlowSynchronousCall(genreName);
		return response.resume(Response.ok(genre).build());
	}
	);
}

關(guān)于“服務(wù)器中如何使用特定的執(zhí)行程序來(lái)阻止操作”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，使各位可以學(xué)到更多知識(shí)，如果覺(jué)得文章不錯(cuò)，請(qǐng)把它分享出去讓更多的人看到。