Method scheduleNext

src/main/java/groovy/concurrent/Agent.java:348–364

()

        }

        private void scheduleNext() {
            if (!queue.isEmpty() && active.compareAndSet(false, true)) {
                delegate.execute(() -> {
                    Runnable task = queue.poll();
                    if (task != null) {
                        try {
                            task.run();
                        } finally {
                            active.set(false);
                            scheduleNext();
                        }
                    } else {
                        active.set(false);
                    }
                });
            }
        }

        /**
         * Prevents further task submission.