Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 117 for clock (0.18 sec)

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

        }
        final ReentrantLock lock = this.lock;
        lock.lock();
    
        boolean satisfied = false;
        try {
          return satisfied = guard.isSatisfied();
        } finally {
          if (!satisfied) {
            lock.unlock();
          }
        }
      }
    
      /**
       * Enters this monitor if the guard is satisfied. Blocks at most the given time acquiring the
       * lock, but does not wait for the guard to be satisfied.
    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-tests/test/com/google/common/util/concurrent/TestThread.java

     * test with reference to the same "lock-like object", and then their interactions with that object
     * are choreographed via the various methods on this class.
     *
     * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
     * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 10.9K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
        // Start the task to put it in the RUNNING state.  Have to use a separate
        // thread because the task will block on the task latch after unblocking
        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 4.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      }
    
      public void testFutureCancellableBeforeFunctionCompletion() throws Exception {
        // Set the result in a separate thread since this test runs the function
        // (which will block) in the same thread.
        new Thread() {
          @Override
          public void run() {
            inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA);
          }
        }.start();
        funcIsWaitingLatch.await();
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/io/Closeables.java

      private Closeables() {}
    
      /**
       * Closes a {@link Closeable}, with control over whether an {@code IOException} may be thrown.
       * This is primarily useful in a finally block, where a thrown exception needs to be logged but
       * not propagated (otherwise the original exception will be lost).
       *
       * <p>If {@code swallowIOException} is true then we never throw {@code IOException} but merely log
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed May 17 14:35:11 GMT 2023
    - 4.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/base/Ascii.java

       * achieved or retained.
       *
       * @since 8.0
       */
      public static final byte SYN = 22;
    
      /**
       * End of Transmission Block: A communication control character used to indicate the end of a
       * block of data for communication purposes. ETB is used for blocking data where the block
       * structure is not necessarily related to the processing format.
       *
       * @since 8.0
       */
      public static final byte ETB = 23;
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Jul 19 15:43:07 GMT 2021
    - 21.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

       */
      public void testRegularFutureInterrupted() throws ExecutionException {
    
        /*
         * Here's the order of events that we want.
         *
         * 1. The client thread begins to block on a get() call to a future.
         * 2. The client thread is interrupted sometime before the result would be
         *   available.
         * 3. We expect the client's get() to throw an InterruptedException.
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 9.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

        }
    
        /*
         * This is an unsynchronized read! After the read, the function returns immediately or acquires
         * the lock to check again. Since an IDLE state was observed inside the preceding synchronized
         * block, and reference field assignment is atomic, this may save reacquiring the lock when
         * another thread or the worker task has cleared the count and set the state.
         *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/cache/CacheBuilderSpec.java

          }
        }
    
        return spec;
      }
    
      /** Returns a CacheBuilderSpec that will prevent caching. */
      public static CacheBuilderSpec disableCaching() {
        // Maximum size of zero is one way to block caching
        return CacheBuilderSpec.parse("maximumSize=0");
      }
    
      /** Returns a CacheBuilder configured according to this instance's specification. */
      CacheBuilder<Object, Object> toCacheBuilder() {
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Mon Aug 22 14:27:44 GMT 2022
    - 18.1K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

        MEDIUM_DELAY_MS = SHORT_DELAY_MS * 10;
        LONG_DELAY_MS = SHORT_DELAY_MS * 200;
      }
    
      /**
       * Returns a timeout in milliseconds to be used in tests that verify that operations block or time
       * out.
       */
      long timeoutMillis() {
        return SHORT_DELAY_MS / 4;
      }
    
      /** Returns a new Date instance representing a time delayMillis milliseconds in the future. */
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 37.7K bytes
    - Viewed (0)
Back to top