最近打算搞一個消息隊列服務,有兩個角色:生產(chǎn)者和消費者,生產(chǎn)者向消息隊列添加任務,消費者負責從消息隊列取任務并執(zhí)行任務。
?
消費者取到任務開始執(zhí)行任務后,如果執(zhí)行時間超過了一個值,消息隊列服務就會向消費者發(fā)送停止任務的消息。
但是由于是阻塞執(zhí)行,消費者無法在執(zhí)行過程中接收到停止任務的消息。
?
看了一下文檔提供的異步執(zhí)行任務的例子,似乎執(zhí)行任務這塊也是阻塞執(zhí)行的,只是把它從主業(yè)務中剝離出來了而已。
?
有人知道什么方法可以異步執(zhí)行任務的時候也能夠接收到停止任務的消息嗎?