Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for queue_limit (0.04 sec)

  1. docs/bucket/notifications/README.md

    To update the configuration, use `mc admin config get` command to get the current configuration.
    
    ```sh
    $ mc admin config get myminio/ notify_mqtt
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (0)
  2. samples/crawler/src/main/java/okhttp3/sample/Crawler.java

      private final ConcurrentHashMap<String, AtomicInteger> hostnames = new ConcurrentHashMap<>();
      private final int hostLimit;
    
      public Crawler(OkHttpClient client, int queueLimit, int hostLimit) {
        this.client = client;
        this.queue = new LinkedBlockingQueue<>(queueLimit);
        this.hostLimit = hostLimit;
      }
    
      private void parallelDrainQueue(int threadCount) {
        ExecutorService executor = Executors.newFixedThreadPool(threadCount);
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jul 23 00:58:06 UTC 2025
    - 5K bytes
    - Viewed (0)
Back to top