[NEMO-147] Guava cache for BlockManagerWorker.pendingBlockLocationRequest

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Labels: runtime
• Assignee: Unassigned
• Reporter: John Yang
• Created: 08/Jul/18 06:45
• Updated: 09/Jul/18 05:52

Description

BlockManagerWorker is accessed by multiple Task executor threads.

  Map<String, CompletableFuture<ControlMessage.Message>> pendingBlockLocationRequest

is used to cache block location query requests.

  pendingBlockLocationRequest.computeIfAbsent

is used to 'reuse' requests.

 

Although the code probably works correctly, it is not deterministic in the sense that one thread waiting for a reply from the master doesn't stop other threads from sending the same request.

Instead, we may want to use Guava cache to ensure that multiple threads are 100% blocked on the same request.