- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 2,234 for toRead (0.12 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
} void stopInterrupting() { shouldStop = true; } } /** Interrupts the current thread after sleeping for the specified delay. */ static void requestInterruptIn(final long time, final TimeUnit unit) { checkNotNull(unit); final Thread interruptee = Thread.currentThread(); new Thread( new Runnable() { @Override public void run() { try {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java
@Override public boolean offer(E o) { assertTrue(Thread.holdsLock(mutex)); return delegate.offer(o); } @Override public @Nullable E poll() { assertTrue(Thread.holdsLock(mutex)); return delegate.poll(); } @Override public E remove() { assertTrue(Thread.holdsLock(mutex)); return delegate.remove(); } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 4.7K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
} private class ThreadHandleImpl implements ThreadHandle { private final Thread thread; private final Set<Thread.State> blockedStates = EnumSet.of(Thread.State.BLOCKED, Thread.State.TIMED_WAITING, Thread.State.WAITING); public ThreadHandleImpl(Thread thread) { this.thread = thread; } @Override public ThreadHandle waitFor() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/shutdown/ShutdownHooks.java
private static final Map<Runnable, Thread> HOOKS = new ConcurrentHashMap<Runnable, Thread>(); public static void addShutdownHook(Runnable shutdownHook) { Thread thread = new Thread(shutdownHook, "gradle-shutdown-hook"); HOOKS.put(shutdownHook, thread); Runtime.getRuntime().addShutdownHook(thread); } public static void removeShutdownHook(Runnable shutdownHook) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 12 05:56:18 UTC 2021 - 2K bytes - Viewed (0) -
android/guava/src/com/google/common/base/internal/Finalizer.java
logger.log( Level.INFO, "Failed to create a thread without inherited thread-local values", t); } } if (thread == null) { thread = new Thread((ThreadGroup) null, finalizer, threadName); } thread.setDaemon(true); try { if (inheritableThreadLocals != null) { inheritableThreadLocals.set(thread, null); } } catch (Throwable t) { logger.log(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Aug 23 12:54:09 UTC 2023 - 9.4K bytes - Viewed (0) -
src/runtime/testdata/testprog/lockosthread.go
// propagated into a newly created thread (via clone), or that thread // is actually being re-used, then we should get scheduled on such a // thread with high likelihood. done := make(chan bool) go func() { runtime.LockOSThread() // Get the CWD and check if this is the same as the main thread's // CWD. Every thread should share the same CWD.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 20:00:09 UTC 2024 - 6.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/async/ServiceLifecycleTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 6.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceWorkerLeaseTest.groovy
thread.blockUntil.worker2 } instant.acquired } } start { thread.blockUntil.worker1 registry.runAsWorkerThread { instant.worker2 thread.block() instant.worker2Finished }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 13.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/InterruptibleTask.java
public final void run() { /* * Set runner thread before checking isDone(). If we were to check isDone() first, the task * might be cancelled before we set the runner thread. That would make it impossible to * interrupt, yet it will still run, since interruptTask will leave the runner value null, * allowing the CAS below to succeed. */ Thread currentThread = Thread.currentThread();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Sep 29 21:34:48 UTC 2023 - 9.9K bytes - Viewed (0) -
testing/internal-testing/src/test/groovy/org/gradle/test/fixtures/concurrent/ConcurrentSpecTest.groovy
} def "can use arbitrary thread to define an instant"() { given: def action = { instant.actionExecuted } def thread = new Thread(action) when: thread.start() thread.join() then: instant.actionExecuted } def "fails when waiting for an instant that is not defined by any thread"() { instant.timeout = 100
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 8.7K bytes - Viewed (0)