Fix a bug for PollOnlyIfExecutorHasCapacity flag about pool size (#666)

spmistry · web-flow · commit 31524fa251fc · 2022-01-14T10:33:43.000-08:00
diff --git a/src/main/java/com/uber/cadence/internal/worker/PollTaskExecutor.java b/src/main/java/com/uber/cadence/internal/worker/PollTaskExecutor.java
@@ -83,7 +83,7 @@ public void process(T task) {
 
   @Override
   public boolean hasCapacity() {
-    return taskExecutor.getActiveCount() < taskExecutor.getPoolSize();
+    return taskExecutor.getActiveCount() < taskExecutor.getMaximumPoolSize();
   }
 
   @Override

Original file line number	Diff line number	Diff line change
`@@ -83,7 +83,7 @@ public void process(T task) {`
`83`	`83`
`84`	`84`	`@Override`
`85`	`85`	`public boolean hasCapacity() {`
`86`		`- return taskExecutor.getActiveCount() < taskExecutor.getPoolSize();`
	`86`	`+ return taskExecutor.getActiveCount() < taskExecutor.getMaximumPoolSize();`
`87`	`87`	`}`
`88`	`88`
`89`	`89`	`@Override`