Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 152 for Coffee (0.1 seconds)

  1. 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
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  2. 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.
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  3. 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
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  4. 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
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 3K bytes
    - Click Count (0)
  5. 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 {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  6. 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.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Jun 24 14:47:15 GMT 2023
    - 1.5K bytes
    - Click Count (0)
  7. 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);
                }
            }
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  8. 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
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.1K bytes
    - Click Count (0)
  9. 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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 33.7K bytes
    - Click Count (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java

                            responseData.setResponseBody(outputFile, true);
                        }
                        ftpClientQueue.offer(client);
                    } catch (final CrawlingAccessException e) {
                        ftpClientQueue.offer(client);
                        throw e;
                    } catch (final Exception e) {
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Mon Nov 24 03:59:47 GMT 2025
    - 40K bytes
    - Click Count (0)
Back to Top