Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 74 for signal (0.18 sec)

  1. android/guava/src/com/google/common/util/concurrent/Monitor.java

       * signal the first active guard that is satisfied. But the corresponding thread may have already
       * been interrupted and is waiting to reacquire the lock while still registered in activeGuards,
       * in which case the signal is a no-op, and the bigger-picture signal is lost unless interrupted
       * threads take special action by participating in the signal-passing game.
       */
    
      /*
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Dec 04 18:22:01 GMT 2023
    - 38.6K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ForwardingCondition.java

      }
    
      @Override
      public boolean awaitUntil(Date deadline) throws InterruptedException {
        return delegate().awaitUntil(deadline);
      }
    
      @Override
      public void signal() {
        delegate().signal();
      }
    
      @Override
      public void signalAll() {
        delegate().signalAll();
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 1.7K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/collect/InternersTest.java

        Interner<Integer> pool = Interners.newWeakInterner();
        assertSame(canonical, pool.intern(canonical));
    
        WeakReference<Integer> signal = new WeakReference<>(canonical);
        canonical = null; // Hint to the JIT that canonical is unreachable
    
        GcFinalization.awaitClear(signal);
        assertSame(not, pool.intern(not));
      }
    
      public void testAsFunction_simplistic() {
        String canonical = "a";
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 4K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

      // TODO: Test blocking to re-enter monitor after being signaled.
      // TODO: Test interrupts with both interruptible and uninterruptible monitor.
      // TODO: Test multiple waiters: If guard is still satisfied, signal next waiter.
      // TODO: Test multiple waiters: If guard is no longer satisfied, do not signal next waiter.
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java

    /**
     * Works around an android bug, where parking for more than INT_MAX seconds can produce an abort
     * signal on 32 bit devices running Android Q.
     */
    @J2ktIncompatible
    @ElementTypesAreNonnullByDefault
    final class OverflowAvoidingLockSupport {
      // Represents the max nanoseconds representable on a linux timespec with a 32 bit tv_sec
      static final long MAX_NANOSECONDS_THRESHOLD = (1L + Integer.MAX_VALUE) * 1_000_000_000L - 1L;
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 1.6K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

      // TODO: Test blocking to re-enter monitor after being signaled.
      // TODO: Test interrupts with both interruptible and uninterruptible monitor.
      // TODO: Test multiple waiters: If guard is still satisfied, signal next waiter.
      // TODO: Test multiple waiters: If guard is no longer satisfied, do not signal next waiter.
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 8K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/collect/InternersTest.java

        Interner<Integer> pool = Interners.newWeakInterner();
        assertSame(canonical, pool.intern(canonical));
    
        WeakReference<Integer> signal = new WeakReference<>(canonical);
        canonical = null; // Hint to the JIT that canonical is unreachable
    
        GcFinalization.awaitClear(signal);
        assertSame(not, pool.intern(not));
      }
    
      public void testAsFunction_simplistic() {
        String canonical = "a";
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 4K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/base/AsciiTest.java

       * A-with-acute-accent, {@code Á} and {@code á}.
       */
      private static final String IGNORED = "`10-=~!@#$%^&*()_+[]\\{}|;':\",./<>?'\u00c1\u00e1\n";
    
      private static final String LOWER = "abcdefghijklmnopqrstuvwxyz";
      private static final String UPPER = "ABCDEFGHIJKLMNOPQRSTUVWXYZ";
    
      public void testToLowerCase() {
        assertEquals(LOWER, Ascii.toLowerCase(UPPER));
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Fri Feb 09 15:49:48 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  9. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java

        @Override
        public final V get() throws InterruptedException, ExecutionException {
          return super.get();
        }
    
        @CanIgnoreReturnValue
        @Override
        public final V get(long timeout, TimeUnit unit)
            throws InterruptedException, ExecutionException, TimeoutException {
          return super.get(timeout, unit);
        }
    
        @Override
        public final boolean isDone() {
          return super.isDone();
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jan 22 19:37:41 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

     *
     * @author Anthony Zana
     */
    public class UninterruptiblesTest extends TestCase {
      private static final String EXPECTED_TAKE = "expectedTake";
    
      /** Timeout to use when we don't expect the timeout to expire. */
      private static final long LONG_DELAY_MS = 2500;
    
      private static final long SLEEP_SLACK = 2;
    
      private final TearDownStack tearDownStack = new TearDownStack();
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 31.7K bytes
    - Viewed (0)
Back to top