Use a fair queue!

slandelle · slandelle · commit bfb9ed2badc7 · 2015-12-07T21:58:47.000+01:00
diff --git a/client/src/main/java/org/asynchttpclient/request/body/generator/BlockingFeedableBodyGenerator.java b/client/src/main/java/org/asynchttpclient/request/body/generator/BlockingFeedableBodyGenerator.java
@@ -21,7 +21,7 @@ public final class BlockingFeedableBodyGenerator extends QueueBasedFeedableBodyG
     private final ArrayBlockingQueue<BodyChunk> queue;
 
     public BlockingFeedableBodyGenerator(int capacity) {
-        queue = new ArrayBlockingQueue<>(capacity);
+        queue = new ArrayBlockingQueue<>(capacity, true);
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -21,7 +21,7 @@ public final class BlockingFeedableBodyGenerator extends QueueBasedFeedableBodyG`
`21`	`21`	`private final ArrayBlockingQueue<BodyChunk> queue;`
`22`	`22`
`23`	`23`	`public BlockingFeedableBodyGenerator(int capacity) {`
`24`		`- queue = new ArrayBlockingQueue<>(capacity);`
	`24`	`+ queue = new ArrayBlockingQueue<>(capacity, true);`
`25`	`25`	`}`
`26`	`26`
`27`	`27`	`@Override`