[FLUME-784] MemoryChannel should poll with timeout on take() rather than block indefinitely

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: NG alpha 1
• Fix Version/s: NG alpha 1
• Assignee: Eric Sammer
• Reporter: Eric Sammer
• Created: 11/Oct/11 06:58
• Updated: 11/Oct/11 08:13
• Resolved: 11/Oct/11 06:59

Description

MemoryChannel is currently completely blocking; it uses ArrayBlockingQueue#put() and #take() rather than offer() and poll(). This is suboptimal for certain runner strategies and background tasks. For now, MemoryChannel should use #poll where x is some reasonable (ideally configurable) timeout.