Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for Bainter (0.14 sec)

  1. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

        final NoOpService service = new NoOpService();
        Thread waiter =
            new Thread() {
              @Override
              public void run() {
                service.awaitTerminated();
              }
            };
        waiter.start();
        service.startAsync().awaitRunning();
        assertEquals(State.RUNNING, service.state());
        service.stopAsync();
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 29.3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/base/Throwables.java

       *
       * @throws IllegalArgumentException if there is a loop in the causal chain
       */
      public static Throwable getRootCause(Throwable throwable) {
        // Keep a second pointer that slowly walks the causal chain. If the fast pointer ever catches
        // the slower pointer, then there's a loop.
        Throwable slowPointer = throwable;
        boolean advanceSlowPointer = false;
    
        Throwable cause;
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Wed Mar 06 15:38:58 GMT 2024
    - 20.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/base/Throwables.java

       *
       * @throws IllegalArgumentException if there is a loop in the causal chain
       */
      public static Throwable getRootCause(Throwable throwable) {
        // Keep a second pointer that slowly walks the causal chain. If the fast pointer ever catches
        // the slower pointer, then there's a loop.
        Throwable slowPointer = throwable;
        boolean advanceSlowPointer = false;
    
        Throwable cause;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Mar 06 15:38:58 GMT 2024
    - 20.6K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        // Check that we wait long enough anyway (presumably as long as MAX_VALUE nanos):
        TimedWaiterThread waiter = new TimedWaiterThread(future, Long.MAX_VALUE, SECONDS);
        waiter.start();
        waiter.awaitWaiting();
    
        future.set(1);
        waiter.join();
      }
    
      @J2ktIncompatible // TODO(b/324550390): Enable
      public void testSetNull() throws Exception {
        future.set(null);
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Monitor.java

       * non-satisfied before reacquiring the lock, and that other thread takes over the responsibility
       * of signaling the next waiter.
       *
       * Unlike the underlying Condition, if we are not careful, an interrupt *can* cause a signal to be
       * lost, because the signal may be sent to a condition whose sole waiter has just been
       * interrupted.
       *
    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)
  6. android/guava/src/com/google/common/base/Ascii.java

       * Normally used as a C string terminator.
       *
       * <p>Although RFC 20 names this as "Null", note that it is distinct from the C/C++ "NULL"
       * pointer.
       *
       * @since 8.0
       */
      public static final byte NUL = 0;
    
      /**
       * Start of Heading: A communication control character used at the beginning of a sequence of
    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. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

            this.runnable = runnable;
            this.executor = executor;
            this.next = next;
          }
        }
      }
    
      // A version of the ExecutionList that uses an explicit tail pointer to keep the nodes in order
      // rather than flipping the stack in execute().
      private static final class NewExecutionListQueue {
        static final Logger log = Logger.getLogger(NewExecutionListQueue.class.getName());
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 17 15:19:38 GMT 2023
    - 20.4K bytes
    - Viewed (0)
  8. guava/src/com/google/common/collect/HashBiMap.java

          throw new IllegalArgumentException("key already present: " + key);
        }
    
        /*
         * The ordering here is important: if we deleted the key entry and then the value entry,
         * the key entry's prev or next pointer might point to the dead value entry, and when we
         * put the new entry in the key entry's position in iteration order, it might invalidate
         * the linked list.
         */
    
        if (oldEntryForValue != null) {
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Fri Oct 13 14:11:58 GMT 2023
    - 24.5K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/RegularImmutableMap.java

       * double the index of the entry in entrySet.asList.)
       *
       * The basic data structure is described in https://en.wikipedia.org/wiki/Open_addressing.
       * The pointer to a key is stored in hashTable[Hashing.smear(key.hashCode()) % table.length],
       * save that if that location is already full, we try the next index, and the next, until we
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 15 22:32:14 GMT 2024
    - 22.7K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

        final NoOpService service = new NoOpService();
        Thread waiter =
            new Thread() {
              @Override
              public void run() {
                service.awaitTerminated();
              }
            };
        waiter.start();
        service.startAsync().awaitRunning();
        assertEquals(State.RUNNING, service.state());
        service.stopAsync();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 29.3K bytes
    - Viewed (0)
Back to top