Make the fairness semantics of the ThrottleRequestFilter configurable

rschildmeijer · rschildmeijer · commit 77bf3be1893e · 2014-03-13T13:41:46.000+01:00
diff --git a/api/src/main/java/org/asynchttpclient/extra/ThrottleRequestFilter.java b/api/src/main/java/org/asynchttpclient/extra/ThrottleRequestFilter.java
@@ -35,8 +35,12 @@ public ThrottleRequestFilter(int maxConnections) {
     }
 
     public ThrottleRequestFilter(int maxConnections, int maxWait) {
-        this.maxWait = maxWait;
-        available = new Semaphore(maxConnections, true);
+      this(maxConnections, maxWait, true);
+    }
+
+    public ThrottleRequestFilter(int maxConnections, int maxWait, boolean fair) {
+      this.maxWait = maxWait;
+      available = new Semaphore(maxConnections, fair);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -35,8 +35,12 @@ public ThrottleRequestFilter(int maxConnections) {`
`35`	`35`	`}`
`36`	`36`
`37`	`37`	`public ThrottleRequestFilter(int maxConnections, int maxWait) {`
`38`		`- this.maxWait = maxWait;`
`39`		`- available = new Semaphore(maxConnections, true);`
	`38`	`+ this(maxConnections, maxWait, true);`
	`39`	`+ }`
	`40`	`+`
	`41`	`+ public ThrottleRequestFilter(int maxConnections, int maxWait, boolean fair) {`
	`42`	`+ this.maxWait = maxWait;`
	`43`	`+ available = new Semaphore(maxConnections, fair);`
`40`	`44`	`}`
`41`	`45`
`42`	`46`	`/**`