decrease yield() frequency during direct hand-off attempts

brettwooldridge · brettwooldridge · commit ee5328d209e3 · 2025-07-29T13:57:51.000+09:00
diff --git a/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java b/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java
@@ -187,11 +187,11 @@ public void requite(final T bagEntry)
    {
       bagEntry.setState(STATE_NOT_IN_USE);
 
-      for (var i = 0; waiters.get() > 0; i++) {
+      for (int i = 1, waiting = waiters.get(); waiting > 0; i++, waiting = waiters.get()) {
          if (bagEntry.getState() != STATE_NOT_IN_USE || handoffQueue.offer(bagEntry)) {
             return;
          }
-         else if ((i & 0xff) == 0xff) {
+         else if ((i & 0xff) == 0xff || (waiting > 1 && i % waiting == 0)) {
             parkNanos(MICROSECONDS.toNanos(10));
          }
          else {

Original file line number	Diff line number	Diff line change
`@@ -187,11 +187,11 @@ public void requite(final T bagEntry)`
`187`	`187`	`{`
`188`	`188`	`bagEntry.setState(STATE_NOT_IN_USE);`
`189`	`189`
`190`		`- for (var i = 0; waiters.get() > 0; i++) {`
	`190`	`+ for (int i = 1, waiting = waiters.get(); waiting > 0; i++, waiting = waiters.get()) {`
`191`	`191`	`if (bagEntry.getState() != STATE_NOT_IN_USE \|\| handoffQueue.offer(bagEntry)) {`
`192`	`192`	`return;`
`193`	`193`	`}`
`194`		`- else if ((i & 0xff) == 0xff) {`
	`194`	`+ else if ((i & 0xff) == 0xff \|\| (waiting > 1 && i % waiting == 0)) {`
`195`	`195`	`parkNanos(MICROSECONDS.toNanos(10));`
`196`	`196`	`}`
`197`	`197`	`else {`