Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 22 for drainTo (0.05 seconds)

  1. guava/src/com/google/common/collect/ForwardingBlockingDeque.java

        return delegate().poll(timeout, unit);
      }
    
      @Override
      public int drainTo(Collection<? super E> c) {
        return delegate().drainTo(c);
      }
    
      @Override
      public int drainTo(Collection<? super E> c, int maxElements) {
        return delegate().drainTo(c, maxElements);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java

        return delegate().poll(timeout, unit);
      }
    
      @Override
      public int drainTo(Collection<? super E> c) {
        return delegate().drainTo(c);
      }
    
      @Override
      public int drainTo(Collection<? super E> c, int maxElements) {
        return delegate().drainTo(c, maxElements);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java

      protected abstract BlockingQueue<E> delegate();
    
      @CanIgnoreReturnValue
      @Override
      public int drainTo(Collection<? super E> c, int maxElements) {
        return delegate().drainTo(c, maxElements);
      }
    
      @CanIgnoreReturnValue
      @Override
      public int drainTo(Collection<? super E> c) {
        return delegate().drainTo(c);
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 3K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ForwardingBlockingDeque.java

        return delegate().poll(timeout, unit);
      }
    
      @Override
      public int drainTo(Collection<? super E> c) {
        return delegate().drainTo(c);
      }
    
      @Override
      public int drainTo(Collection<? super E> c, int maxElements) {
        return delegate().drainTo(c, maxElements);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/TestLogHandler.kt

            try {
              base.evaluate()
            } finally {
              afterEach(null)
            }
          }
        }
    
      fun takeAll(): List<String> {
        val list = mutableListOf<String>()
        logs.drainTo(list)
        return list
      }
    
      fun take(): String =
        logs.poll(10, TimeUnit.SECONDS)
          ?: throw AssertionError("Timed out waiting for log message.")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 2.5K bytes
    - Click Count (0)
  6. compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java

        }
    
        private void feedConsumer() {
            final ArrayList<Exchange> batch = new ArrayList<>(batchMaxSize);
            try {
                while (true) {
                    batch.clear();
                    if (eventQueue.drainTo(batch, BATCH_MAX_SIZE) == 0) {
                        batch.add(eventQueue.take());
                    }
                    demux(batch);
                }
            } catch (InterruptedException e) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Nov 08 08:49:11 GMT 2024
    - 8.4K bytes
    - Click Count (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/transfer/SimplexTransferListener.java

        private void feedConsumer() {
            final ArrayList<Exchange> batch = new ArrayList<>(batchMaxSize);
            try {
                while (true) {
                    batch.clear();
                    if (eventQueue.drainTo(batch, BATCH_MAX_SIZE) == 0) {
                        batch.add(eventQueue.take());
                    }
                    demux(batch);
                }
            } catch (InterruptedException ignored) {
                // silent
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Thu Feb 06 11:28:05 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  8. src/test/java/org/codelibs/fess/helper/LogNotificationHelperTest.java

                            // Periodically drain
                            if (i % 50 == 49) {
                                List<LogNotificationEvent> drained = helper.drainAll();
                                totalDrained.addAndGet(drained.size());
                            }
                        }
                    } catch (InterruptedException e) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/timer/LogNotificationTargetTest.java

                    .offer(new LogNotificationEvent(System.currentTimeMillis(), "WARN", "org.test", "msg2", null));
    
            // expired() will drain buffer then fail on OpenSearch (not available) but should not throw
            logNotificationTarget.expired();
    
            // Buffer should be empty after expired() drained it
            List<LogNotificationEvent> remaining = ComponentUtil.getLogNotificationHelper().drainAll();
            assertEquals(0, remaining.size());
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  10. docs/contribute/concurrency.md

    #### Do-stuff-later pool
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Click Count (0)
Back to Top