From e9a749e17e28428b942f32bd406db415a98f83e4 Mon Sep 17 00:00:00 2001 From: Rob Zienert Date: Wed, 29 Aug 2018 13:59:45 -0700 Subject: [PATCH] fix(core): Revert to a countdown executor fill strategy (#47) --- .../src/main/kotlin/com/netflix/spinnaker/q/QueueProcessor.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/keiko-core/src/main/kotlin/com/netflix/spinnaker/q/QueueProcessor.kt b/keiko-core/src/main/kotlin/com/netflix/spinnaker/q/QueueProcessor.kt index 063a0ad..f8e309c 100644 --- a/keiko-core/src/main/kotlin/com/netflix/spinnaker/q/QueueProcessor.kt +++ b/keiko-core/src/main/kotlin/com/netflix/spinnaker/q/QueueProcessor.kt @@ -57,7 +57,7 @@ class QueueProcessor( ifEnabled { if (executor.hasCapacity()) { if (fillExecutorEachCycle) { - while (executor.hasCapacity()) { + executor.availableCapacity().downTo(1).forEach { pollOnce() } } else {