Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for queues (0.09 sec)

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

        WeakValueReferenceImpl(ReferenceQueue<V> queue, V referent, E entry) {
          super(referent, queue);
          this.entry = entry;
        }
    
        @Override
        public E getEntry() {
          return entry;
        }
    
        @Override
        public WeakValueReference<K, V, E> copyFor(ReferenceQueue<V> queue, E entry) {
          return new WeakValueReferenceImpl<>(queue, get(), entry);
        }
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

        WeakValueReferenceImpl(ReferenceQueue<V> queue, V referent, E entry) {
          super(referent, queue);
          this.entry = entry;
        }
    
        @Override
        public E getEntry() {
          return entry;
        }
    
        @Override
        public WeakValueReference<K, V, E> copyFor(ReferenceQueue<V> queue, E entry) {
          return new WeakValueReferenceImpl<>(queue, get(), entry);
        }
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/cache/CacheBuilder.java

       * once after loading completes). Much internal cache management is performed at the segment
       * granularity. For example, access queues and write queues are kept per segment when they are
       * required by the selected eviction algorithm. As such, when writing unit tests it is not
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 52K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

          Http2Connection.Builder(true, taskRunner)
            .socket(socket)
            .pushObserver(IGNORE)
            .build()
        connection.start(sendConnectionPreface = false)
        val queues = taskRunner.activeQueues()
        assertThat(queues).hasSize(1)
      }
    
      private fun data(byteCount: Int): Buffer = Buffer().write(ByteArray(byteCount))
    
      private fun assertStreamData(
        expected: String?,
        source: Source?,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/cache/CacheBuilder.java

       * once after loading completes). Much internal cache management is performed at the segment
       * granularity. For example, access queues and write queues are kept per segment when they are
       * required by the selected eviction algorithm. As such, when writing unit tests it is not
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/Sets.java

    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Static utility methods pertaining to {@link Set} instances. Also see this class's counterparts
     * {@link Lists}, {@link Maps} and {@link Queues}.
     *
     * <p>See the Guava User Guide article on <a href=
     * "https://github.com/google/guava/wiki/CollectionUtilitiesExplained#sets">{@code Sets}</a>.
     *
     * @author Kevin Bourrillion
     * @author Jared Levy
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  7. docs/bucket/notifications/README.md

    result = channel.queue_declare(exclusive=False)
    queue_name = result.method.queue
    
    channel.queue_bind(exchange='bucketevents',
                       queue=queue_name)
    
    print(' [*] Waiting for logs. To exit press CTRL+C')
    
    def callback(ch, method, properties, body):
        print(" [x] %r" % body)
    
    channel.basic_consume(callback,
                          queue=queue_name,
                          no_ack=False)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  8. docs/metrics/prometheus/grafana/replication/minio-replication-node.json

              "interval": "1m",
              "intervalFactor": 2,
              "legendFormat": "{{server}}",
              "refId": "A"
            }
          ],
          "title": "Avg. Queued Size",
          "type": "timeseries"
        },
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"
          },
          "fieldConfig": {
            "defaults": {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 13 22:26:54 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/Synchronized.java

      }
    
      static <E extends @Nullable Object> Queue<E> queue(Queue<E> queue, @CheckForNull Object mutex) {
        return (queue instanceof SynchronizedQueue) ? queue : new SynchronizedQueue<E>(queue, mutex);
      }
    
      static class SynchronizedQueue<E extends @Nullable Object> extends SynchronizedCollection<E>
          implements Queue<E> {
    
        SynchronizedQueue(Queue<E> delegate, @CheckForNull Object mutex) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 53.4K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/Synchronized.java

      }
    
      static <E extends @Nullable Object> Queue<E> queue(Queue<E> queue, @CheckForNull Object mutex) {
        return (queue instanceof SynchronizedQueue) ? queue : new SynchronizedQueue<E>(queue, mutex);
      }
    
      static class SynchronizedQueue<E extends @Nullable Object> extends SynchronizedCollection<E>
          implements Queue<E> {
    
        SynchronizedQueue(Queue<E> delegate, @CheckForNull Object mutex) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 57.2K bytes
    - Viewed (0)
Back to top