- Sort Score
- Num 10 results
- Language All
Results 1 - 8 of 8 for isInterruptible (0.35 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
} else { assertTrue(desc, isBoolean(method)); } switch (method.getExceptionTypes().length) { case 0: assertFalse(desc, isInterruptible(method)); break; case 1: assertTrue(desc, isInterruptible(method)); break; default: fail(desc); } if (isEnterIf(method)) { assertTrue(desc, isGuarded(method));Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
} else { assertTrue(desc, isBoolean(method)); } switch (method.getExceptionTypes().length) { case 0: assertFalse(desc, isInterruptible(method)); break; case 1: assertTrue(desc, isInterruptible(method)); break; default: fail(desc); } if (isEnterIf(method)) { assertTrue(desc, isGuarded(method));Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java
this.satisfied = satisfied; } } private final boolean interruptible; private Monitor monitor; private final TearDownStack tearDownStack = new TearDownStack(); private TestThread<Monitor> thread1; private TestThread<Monitor> thread2; protected MonitorTestCase(boolean interruptible) { this.interruptible = interruptible; } @Override protected final void setUp() throws Exception {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java
this.satisfied = satisfied; } } private final boolean interruptible; private Monitor monitor; private final TearDownStack tearDownStack = new TearDownStack(); private TestThread<Monitor> thread1; private TestThread<Monitor> thread2; protected MonitorTestCase(boolean interruptible) { this.interruptible = interruptible; } @Override protected final void setUp() throws Exception {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleMonitorTest.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import org.jspecify.annotations.NullUnmarked; /** * Tests for {@link Monitor}'s interruptible methods. * * @author Justin T. Sampson */ @NullUnmarked @GwtIncompatible @J2ktIncompatible public class InterruptibleMonitorTest extends MonitorTestCase { public InterruptibleMonitorTest() {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleMonitorTest.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import org.jspecify.annotations.NullUnmarked; /** * Tests for {@link Monitor}'s interruptible methods. * * @author Justin T. Sampson */ @NullUnmarked @GwtIncompatible @J2ktIncompatible public class InterruptibleMonitorTest extends MonitorTestCase { public InterruptibleMonitorTest() {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
* interrupting thread. In theory, interruptTask() should be very fast, but due to * InterruptibleChannel and JavaLangAccess.blockedOn(Thread, Interruptible), it isn't * predictable what work might be done. (e.g., close a file and flush buffers to disk). To * protect ourselves from this, we park ourselves and tell our interrupter that we did so. */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 10K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
import java.util.concurrent.TimeoutException; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import org.jspecify.annotations.Nullable; /** * Utilities for treating interruptible operations as uninterruptible. In all cases, if a thread is * interrupted during such a call, the call continues to block until the result is available or the * timeout elapses, and only then re-interrupts the thread. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 23:24:32 GMT 2026 - 22.5K bytes - Click Count (0)