- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for InterruptibleRunnable (0.16 sec)
-
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/InterruptibleRunnable.java
*/ public final class InterruptibleRunnable implements Runnable { private final Lock stateLock = new ReentrantLock(); private final Runnable delegate; private boolean interrupted; private Thread thread; public InterruptibleRunnable(Runnable delegate) { this.delegate = delegate; } @Override public void run() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/AsyncDispatch.java
private final LinkedList<T> queue = new LinkedList<T>(); private final Executor executor; private final int maxQueueSize; private final Map<Dispatch<?>, InterruptibleRunnable> dispatchers = new HashMap<Dispatch<?>, InterruptibleRunnable>(); private State state; public AsyncDispatch(Executor executor) { this(executor, null, MAX_QUEUE_SIZE); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 6.7K bytes - Viewed (0)