-
Notifications
You must be signed in to change notification settings - Fork 107
performance optimization: choice of concurrent queue #287
Open
Description
defines a
this.messages = new ConcurrentLinkedQueue<>();
to buffer messages before sending. This results in a lot of object allocations as every message also gets a queue node created. It would be useful to consider a bounded alternative like ArrayBlockingQueue with ~million entries (configurable with a property). It looks like offer is already being used instead of add so this would also cap the memory limits of the application.
Metadata
Metadata
Assignees
Labels
No labels
Type
Fields
Give feedbackNo fields configured for issues without a type.