Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 159 for coffee (0.89 sec)

  1. guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java

        return delegate().drainTo(c);
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offer(e, timeout, unit);
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

        private final Deque<E> delegate = new LinkedList<>();
        private final Object mutex = new Object[0]; // something Serializable
    
        @Override
        public boolean offer(E o) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.offer(o);
        }
    
        @Override
        public @Nullable E poll() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.poll();
        }
    
        @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java

     * to the methods of the delegate. For example, overriding {@link #add} alone <b>will not</b> change
     * the behaviour of {@link #offer} which can lead to unexpected behaviour. In this case, you should
     * override {@code offer} as well, either providing your own implementation, or delegating to the
     * provided {@code standardOffer} method.
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

       */
      @CanIgnoreReturnValue // pushed down from class to method
      @Override
      public boolean add(E e) {
        return offer(e);
      }
    
      /**
       * Inserts the specified element into this priority queue.
       *
       * @param e the element to add
       * @return {@code true} (as specified by {@link Queue#offer})
       * @throws ClassCastException if the specified element cannot be compared with elements currently
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java

        return delegate().drainTo(c);
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offer(e, timeout, unit);
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 3K bytes
    - Viewed (0)
  6. okhttp-testing-support/src/main/kotlin/okhttp3/EventRecorder.kt

        for (lock in forbiddenLocks) {
          assertThat(Thread.holdsLock(lock), lock.toString()).isFalse()
        }
    
        if (enforceOrder) {
          checkForStartEvent(e)
        }
    
        eventsForMatching.offer(e)
        eventSequence.offer(e)
      }
    
      private fun checkForStartEvent(e: CallEvent) {
        if (eventsForMatching.isEmpty()) {
          assertThat(e).matchesPredicate { it is CallStart || it is Canceled }
        } else {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  7. docs/fr/docs/deployment/index.md

    utilisateurs**.
    
    Pour une **API Web**, cela implique normalement de la placer sur une **machine distante**, avec un **programme serveur**
    qui offre de bonnes performances, une bonne stabilité, _etc._, afin que vos **utilisateurs** puissent **accéder** à
    l'application efficacement et sans interruption ni problème.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Jun 24 14:47:15 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java

                    RdmaMemoryRegion region = provider.registerMemory(buffer, EnumSet.of(RdmaAccess.LOCAL_READ, RdmaAccess.REMOTE_READ));
                    availableSendRegions.offer(region);
                    totalAllocated.incrementAndGet();
                } catch (IOException e) {
                    log.warn("Failed to pre-allocate send buffer", e);
                }
            }
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/ForwardingDeque.java

     * methods of the delegate. For example, overriding {@link #add} alone <b>will not</b> change the
     * behavior of {@link #offer} which can lead to unexpected behavior. In this case, you should
     * override {@code offer} as well.
     *
     * <p><b>{@code default} method warning:</b> This class does <i>not</i> forward calls to {@code
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. LICENSE

        written offer to provide the Corresponding Source.  This
        alternative is allowed only occasionally and noncommercially, and
        only if you received the object code with such an offer, in accord
        with subsection 6b.
    
        d) Convey the object code by offering access from a designated
        place (gratis or for a charge), and offer equivalent access to the
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 33.7K bytes
    - Viewed (0)
Back to top