[ROCKETMQ-301] Async callback timeout

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Feedback Received
• Affects Version/s: 4.0.0-incubating, 4.1.0-incubating
• Fix Version/s: 4.2.0
• Component/s: rocketmq-remoting
• Flags: Important
• Assignee: Von Gosling
• Reporter: fucongwang
• Created: 07/Oct/17 07:02
• Updated: 13/Dec/17 11:34
• Resolved: 13/Dec/17 11:34

Description

Motivation:
I found that ResponseFuture used some tips to keep future callback from being called multiple and keep semaphoreAsync from being released multiple, I think it was not elegant, and scanResponseTable would scan the on-going request list, it was too heavy.

Modification:

• ScheduleExecutor replaces Timer, to issue per callback timeout. when timeout, check future is done? if not , clear responseTable item and invoke callback, if done, just clear responseTable item.

• ResponseFuture add isDone method, to check if future is done.