[HAMA-568] Add faster synchronized collections for message queues

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.6.3
• Assignee: Edward J. Yoon
• Reporter: Thomas Jungblut
• Created: 03/May/12 15:38
• Updated: 02/Apr/14 10:15
• Resolved: 02/Apr/14 10:15

Description

Currently the synchronized messaging (accessed concurrently via RPC) is done with a single mutex object. See org.apache.hama.bsp.message.SynchronizedQueue.

This can be improved for memory queue by adding the ConcurrentLinkedQueue from Java since it has higher throughput.

Needless to say, we should add some custom synchronized version of a queue, maybe through a factory class in the normal version.

Issue Links

• relates to: HAMA-566 Add a disk-based queue