@@ -95,7 +95,7 @@ public final class WorkerThreadPoolHierarchicalTestExecutorService implements Hi
9595 directly.
9696 */
9797
98- private static final Logger LOGGER = LoggerFactory .getLogger (WorkerThreadPoolHierarchicalTestExecutorService .class );
98+ private static final Logger logger = LoggerFactory .getLogger (WorkerThreadPoolHierarchicalTestExecutorService .class );
9999
100100 private final WorkQueue workQueue = new WorkQueue ();
101101 private final ExecutorService executor ;
@@ -137,18 +137,18 @@ public final class WorkerThreadPoolHierarchicalTestExecutorService implements Hi
137137 executor = new ThreadPoolExecutor (configuration .getCorePoolSize (), configuration .getMaxPoolSize (),
138138 configuration .getKeepAliveSeconds (), SECONDS , new SynchronousQueue <>(), threadFactory ,
139139 rejectedExecutionHandler );
140- LOGGER .trace (() -> "initialized thread pool for parallelism of " + configuration .getParallelism ());
140+ logger .trace (() -> "initialized thread pool for parallelism of " + configuration .getParallelism ());
141141 }
142142
143143 @ Override
144144 public void close () {
145- LOGGER .trace (() -> "shutting down thread pool" );
145+ logger .trace (() -> "shutting down thread pool" );
146146 executor .shutdownNow ();
147147 }
148148
149149 @ Override
150150 public Future <@ Nullable Void > submit (TestTask testTask ) {
151- LOGGER .trace (() -> "submit: " + testTask );
151+ logger .trace (() -> "submit: " + testTask );
152152
153153 var workerThread = WorkerThread .get ();
154154 if (workerThread == null ) {
@@ -173,7 +173,7 @@ public void close() {
173173 */
174174 @ Override
175175 public void invokeAll (List <? extends TestTask > testTasks ) {
176- LOGGER .trace (() -> "invokeAll: " + testTasks );
176+ logger .trace (() -> "invokeAll: " + testTasks );
177177
178178 var workerThread = WorkerThread .get ();
179179 Preconditions .condition (workerThread != null && workerThread .executor () == this ,
@@ -219,13 +219,13 @@ private record RunLeaseAwareWorker(WorkerLease workerLease, BooleanSupplier pare
219219
220220 @ Override
221221 public void run () {
222- LOGGER .trace (() -> "starting worker" );
222+ logger .trace (() -> "starting worker" );
223223 try {
224224 WorkerThread .getOrThrow ().processQueueEntries (workerLease , parentDoneCondition );
225225 }
226226 finally {
227227 workerLease .release (parentDoneCondition );
228- LOGGER .trace (() -> "stopping worker" );
228+ logger .trace (() -> "stopping worker" );
229229 }
230230 }
231231 }
@@ -286,11 +286,11 @@ void processQueueEntries(WorkerLease workerLease, BooleanSupplier doneCondition)
286286 this .workerLease = workerLease ;
287287 while (!executor .isShutdown ()) {
288288 if (doneCondition .getAsBoolean ()) {
289- LOGGER .trace (() -> "yielding resource lock" );
289+ logger .trace (() -> "yielding resource lock" );
290290 break ;
291291 }
292292 if (workQueue .isEmpty ()) {
293- LOGGER .trace (() -> "no queue entries available" );
293+ logger .trace (() -> "no queue entries available" );
294294 break ;
295295 }
296296 processQueueEntries ();
@@ -415,7 +415,7 @@ private WorkStealResult tryToStealWork(WorkQueue.Entry entry, BlockingMode block
415415 }
416416 var claimed = workQueue .remove (entry );
417417 if (claimed ) {
418- LOGGER .trace (() -> "stole work: " + entry .task );
418+ logger .trace (() -> "stole work: " + entry .task );
419419 var executed = executeStolenWork (entry , blockingMode );
420420 if (executed ) {
421421 return WorkStealResult .EXECUTED_BY_THIS_WORKER ;
@@ -439,7 +439,7 @@ private void waitFor(Map<WorkStealResult, List<WorkQueue.Entry>> queueEntriesByR
439439 }
440440 else {
441441 runBlocking (future ::isDone , () -> {
442- LOGGER .trace (() -> "blocking for forked children : %s" .formatted (children ));
442+ logger .trace (() -> "blocking for forked children : %s" .formatted (children ));
443443 return future .join ();
444444 });
445445 }
@@ -457,7 +457,7 @@ private void executeAll(List<? extends TestTask> children) {
457457 if (children .isEmpty ()) {
458458 return ;
459459 }
460- LOGGER .trace (() -> "running %d children directly" .formatted (children .size ()));
460+ logger .trace (() -> "running %d children directly" .formatted (children .size ()));
461461 if (children .size () == 1 ) {
462462 executeTask (children .get (0 ));
463463 return ;
@@ -509,48 +509,48 @@ private void executeTask(TestTask testTask) {
509509 if (!executed ) {
510510 var resourceLock = testTask .getResourceLock ();
511511 try (var ignored = runBlocking (() -> false , () -> {
512- LOGGER .trace (() -> "blocking for resource lock: " + resourceLock );
512+ logger .trace (() -> "blocking for resource lock: " + resourceLock );
513513 return resourceLock .acquire ();
514514 })) {
515- LOGGER .trace (() -> "acquired resource lock: " + resourceLock );
515+ logger .trace (() -> "acquired resource lock: " + resourceLock );
516516 doExecute (testTask );
517517 }
518518 catch (InterruptedException ex ) {
519519 Thread .currentThread ().interrupt ();
520520 }
521521 finally {
522- LOGGER .trace (() -> "released resource lock: " + resourceLock );
522+ logger .trace (() -> "released resource lock: " + resourceLock );
523523 }
524524 }
525525 }
526526
527527 private boolean tryExecuteTask (TestTask testTask ) {
528528 var resourceLock = testTask .getResourceLock ();
529529 if (resourceLock .tryAcquire ()) {
530- LOGGER .trace (() -> "acquired resource lock: " + resourceLock );
530+ logger .trace (() -> "acquired resource lock: " + resourceLock );
531531 try (resourceLock ) {
532532 doExecute (testTask );
533533 return true ;
534534 }
535535 finally {
536- LOGGER .trace (() -> "released resource lock: " + resourceLock );
536+ logger .trace (() -> "released resource lock: " + resourceLock );
537537 }
538538 }
539539 else {
540- LOGGER .trace (() -> "failed to acquire resource lock: " + resourceLock );
540+ logger .trace (() -> "failed to acquire resource lock: " + resourceLock );
541541 }
542542 return false ;
543543 }
544544
545545 private void doExecute (TestTask testTask ) {
546- LOGGER .trace (() -> "executing: " + testTask );
546+ logger .trace (() -> "executing: " + testTask );
547547 stateStack .push (new State ());
548548 try {
549549 testTask .execute ();
550550 }
551551 finally {
552552 stateStack .pop ();
553- LOGGER .trace (() -> "finished executing: " + testTask );
553+ logger .trace (() -> "finished executing: " + testTask );
554554 }
555555 }
556556
@@ -650,7 +650,7 @@ private static class WorkStealingFuture extends BlockingAwareFuture<@Nullable Vo
650650 if (entry .future .isDone ()) {
651651 return callable .call ();
652652 }
653- LOGGER .trace (() -> "blocking for child task: " + entry .task );
653+ logger .trace (() -> "blocking for child task: " + entry .task );
654654 return workerThread .runBlocking (entry .future ::isDone , () -> {
655655 try {
656656 return callable .call ();
@@ -673,7 +673,7 @@ private static class WorkQueue implements Iterable<WorkQueue.Entry> {
673673
674674 Entry add (TestTask task , int index ) {
675675 Entry entry = new Entry (task , index );
676- LOGGER .trace (() -> "forking: " + entry .task );
676+ logger .trace (() -> "forking: " + entry .task );
677677 return doAdd (entry );
678678 }
679679
@@ -682,7 +682,7 @@ void addAll(Collection<Entry> entries) {
682682 }
683683
684684 void reAdd (Entry entry ) {
685- LOGGER .trace (() -> "re-enqueuing: " + entry .task );
685+ logger .trace (() -> "re-enqueuing: " + entry .task );
686686 doAdd (entry );
687687 }
688688
@@ -726,10 +726,10 @@ private static final class Entry {
726726 this .future = new CompletableFuture <>();
727727 this .future .whenComplete ((__ , t ) -> {
728728 if (t == null ) {
729- LOGGER .trace (() -> "completed normally: " + task );
729+ logger .trace (() -> "completed normally: " + task );
730730 }
731731 else {
732- LOGGER .trace (t , () -> "completed exceptionally: " + task );
732+ logger .trace (t , () -> "completed exceptionally: " + task );
733733 }
734734 });
735735 this .task = task ;
@@ -828,7 +828,7 @@ static class WorkerLeaseManager {
828828 WorkerLease tryAcquire () {
829829 boolean acquired = semaphore .tryAcquire ();
830830 if (acquired ) {
831- LOGGER .trace (() -> "acquired worker lease for new worker (available: %d)" .formatted (
831+ logger .trace (() -> "acquired worker lease for new worker (available: %d)" .formatted (
832832 semaphore .availablePermits ()));
833833 return new WorkerLease (this ::release );
834834 }
@@ -837,7 +837,7 @@ WorkerLease tryAcquire() {
837837
838838 private ReacquisitionToken release (BooleanSupplier doneCondition ) {
839839 semaphore .release ();
840- LOGGER .trace (() -> "release worker lease (available: %d)" .formatted (semaphore .availablePermits ()));
840+ logger .trace (() -> "release worker lease (available: %d)" .formatted (semaphore .availablePermits ()));
841841 compensation .accept (doneCondition );
842842 return new ReacquisitionToken ();
843843 }
@@ -850,7 +850,7 @@ void reacquire() throws InterruptedException {
850850 Preconditions .condition (!used , "Lease was already reacquired" );
851851 used = true ;
852852 semaphore .acquire ();
853- LOGGER .trace (() -> "reacquired worker lease (available: %d)" .formatted (semaphore .availablePermits ()));
853+ logger .trace (() -> "reacquired worker lease (available: %d)" .formatted (semaphore .availablePermits ()));
854854 }
855855 }
856856
0 commit comments