File tree Expand file tree Collapse file tree
temporal-sdk/src/main/java/io/temporal/internal/worker Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1111import io .temporal .worker .tuning .SlotSupplierFuture ;
1212import java .util .*;
1313import java .util .concurrent .*;
14- import java .util .concurrent .atomic .AtomicInteger ;
1514import java .util .concurrent .locks .Condition ;
1615import java .util .concurrent .locks .Lock ;
1716import java .util .concurrent .locks .ReentrantLock ;
@@ -311,8 +310,9 @@ public void run() {
311310 }
312311
313312 /**
314- * PollQueueBalancer is used to ensure that at least one poller is running for each task. This is
315- * necessary to avoid one poller from consuming all the slots and starving other pollers.
313+ * PollQueueBalancer is used to ensure that at least one poll request is running for each task
314+ * type. This is necessary to avoid one task type from consuming all the slots and starving other
315+ * pollers.
316316 */
317317 @ ThreadSafe
318318 class PollQueueBalancer {
You can’t perform that action at this time.
0 commit comments