Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,637 for Signal (0.26 sec)

  1. 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)
  2. 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)
  3. 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)
  4. android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

        }
      }
    
      private final boolean interruptible;
      private Monitor monitor;
      private final TearDownStack tearDownStack = new TearDownStack(true);
      private TestThread<Monitor> thread1;
      private TestThread<Monitor> thread2;
    
      protected MonitorTestCase(boolean interruptible) {
        this.interruptible = interruptible;
      }
    
      @Override
      protected final void setUp() throws Exception {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  5. 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)
  6. futures/listenablefuture9999/pom.xml

      </parent>
      <artifactId>listenablefuture</artifactId>
      <version>9999.0-empty-to-avoid-conflict-with-guava</version>
      <name>Guava ListenableFuture only</name>
      <description>
        An empty artifact that Guava depends on to signal that it is providing
        ListenableFuture -- but is also available in a second "version" that
        contains com.google.common.util.concurrent.ListenableFuture class, without
        any other Guava classes. The idea is:
    
    XML
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 12 21:42:09 GMT 2018
    - 2.2K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

        }
      }
    
      private final boolean interruptible;
      private Monitor monitor;
      private final TearDownStack tearDownStack = new TearDownStack(true);
      private TestThread<Monitor> thread1;
      private TestThread<Monitor> thread2;
    
      protected MonitorTestCase(boolean interruptible) {
        this.interruptible = interruptible;
      }
    
      @Override
      protected final void setUp() throws Exception {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 8K 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 Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Feb 09 15:49:48 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  9. 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)
  10. 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 Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 4K bytes
    - Viewed (0)
Back to top