Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 415 for queued (0.07 seconds)

  1. src/main/java/jcifs/SidResolver.java

         *
         * @param tc
         *            context to use
         * @param authorityServerName
         *            The hostname of the server that should be queried. For maximum efficiency this should be the hostname
         *            of a domain controller however a member server will work as well and a domain controller may not
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  2. apache-maven/src/assembly/maven/bin/JvmConfigParser.java

     *
     * If output-file is provided, writes result to that file (avoids Windows file locking issues).
     * Otherwise, outputs to stdout.
     *
     * Outputs: Single line with space-separated quoted arguments (safe for batch scripts)
     */
    public class JvmConfigParser {
        public static void main(String[] args) {
            if (args.length < 2 || args.length > 3) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Dec 10 16:40:06 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  3. guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java

    import com.google.common.collect.testing.features.CollectionFeature;
    import com.google.common.collect.testing.features.CollectionSize;
    import org.junit.Ignore;
    
    /**
     * A generic JUnit test which tests {@code poll()} operations on a queue. Can't be invoked directly;
     * please see {@link com.google.common.collect.testing.CollectionTestSuiteBuilder}.
     *
     * @author Jared Levy
     */
    @GwtCompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Nov 14 23:40:07 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  4. guava-testlib/src/com/google/common/collect/testing/testers/QueueRemoveTester.java

    import com.google.common.collect.testing.features.CollectionSize;
    import java.util.NoSuchElementException;
    import org.junit.Ignore;
    
    /**
     * A generic JUnit test which tests {@code remove()} operations on a queue. Can't be invoked
     * directly; please see {@link com.google.common.collect.testing.CollectionTestSuiteBuilder}.
     *
     * @author Jared Levy
     */
    @GwtCompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Nov 14 23:40:07 GMT 2024
    - 2.6K bytes
    - Click Count (0)
  5. cmd/metrics-v3-audit.go

    	auditFailedMessagesMD = NewCounterMD(auditFailedMessages,
    		"Total number of messages that failed to send since start",
    		targetID)
    	auditTargetQueueLengthMD = NewGaugeMD(auditTargetQueueLength,
    		"Number of unsent messages in queue for target",
    		targetID)
    	auditTotalMessagesMD = NewCounterMD(auditTotalMessages,
    		"Total number of messages sent since start",
    		targetID)
    )
    
    // loadAuditMetrics - `MetricsLoaderFn` for audit
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 10 14:50:39 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/Iterators.java

          return !queue.isEmpty();
        }
    
        @Override
        @ParametricNullness
        public T next() {
          IndexedIterator<T> nextIndexed = queue.remove();
          PeekingIterator<T> nextIter = nextIndexed.iterator;
          T next = nextIter.next();
          if (nextIter.hasNext()) {
            queue.add(nextIndexed);
          }
          return next;
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 16 12:42:11 GMT 2025
    - 51.4K bytes
    - Click Count (0)
  7. guava/src/com/google/common/collect/Iterators.java

          return !queue.isEmpty();
        }
    
        @Override
        @ParametricNullness
        public T next() {
          IndexedIterator<T> nextIndexed = queue.remove();
          PeekingIterator<T> nextIter = nextIndexed.iterator;
          T next = nextIter.next();
          if (nextIter.hasNext()) {
            queue.add(nextIndexed);
          }
          return next;
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 16 12:42:11 GMT 2025
    - 51.4K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/cache/TestingRemovalListeners.java

      static <K, V> CountingRemovalListener<K, V> countingRemovalListener() {
        return new CountingRemovalListener<>();
      }
    
      /** {@link RemovalListener} that adds all {@link RemovalNotification} objects to a queue. */
      @J2ktIncompatible
      @GwtIncompatible // ConcurrentLinkedQueue
      static class QueuingRemovalListener<K, V> extends ConcurrentLinkedQueue<RemovalNotification<K, V>>
          implements RemovalListener<K, V> {
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 13:13:59 GMT 2026
    - 3.2K bytes
    - Click Count (0)
  9. internal/config/notify/help.go

    		},
    		config.HelpKV{
    			Key:         target.AmqpAutoDeleted,
    			Description: "auto delete queue when set to 'on', when there are no consumers",
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.AmqpDeliveryMode,
    			Description: "set to '1' for non-persistent or '2' for persistent queue",
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 19.2K bytes
    - Click Count (0)
  10. android/guava-testlib/src/com/google/common/collect/testing/testers/QueueRemoveTester.java

    import com.google.common.collect.testing.features.CollectionSize;
    import java.util.NoSuchElementException;
    import org.junit.Ignore;
    
    /**
     * A generic JUnit test which tests {@code remove()} operations on a queue. Can't be invoked
     * directly; please see {@link com.google.common.collect.testing.CollectionTestSuiteBuilder}.
     *
     * @author Jared Levy
     */
    @GwtCompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Nov 14 23:40:07 GMT 2024
    - 2.6K bytes
    - Click Count (0)
Back to Top