Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 30 for blocking (0.11 sec)

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

       * Drains the queue as {@link BlockingQueue#drainTo(Collection, int)}, but if the requested {@code
       * numElements} elements are not available, it will wait for them up to the specified timeout.
       *
       * @param q the blocking queue to be drained
       * @param buffer where to add the transferred elements
       * @param numElements the number of elements to be waited for
       * @param timeout how long to wait before giving up
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/Queues.java

       * Drains the queue as {@link BlockingQueue#drainTo(Collection, int)}, but if the requested {@code
       * numElements} elements are not available, it will wait for them up to the specified timeout.
       *
       * @param q the blocking queue to be drained
       * @param buffer where to add the transferred elements
       * @param numElements the number of elements to be waited for
       * @param timeout how long to wait before giving up
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    	return jbytes, ErrNone
    }
    
    // healSource denotes single entity and heal option.
    type healSource struct {
    	bucket    string
    	object    string
    	versionID string
    	noWait    bool             // a non blocking call, if task queue is full return right away.
    	opts      *madmin.HealOpts // optional heal option overrides default setting
    }
    
    // healSequence - state for each heal sequence initiated on the
    // server.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  4. cmd/xl-storage.go

    			targetPath2,
    		} {
    			if target == "" {
    				continue
    			}
    			select {
    			case s.immediatePurge <- target:
    			default:
    				// Too much back pressure, we will perform the delete
    				// blocking at this point we need to serialize operations.
    				removeAll(target)
    			}
    		}
    	}
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  5. CONTRIBUTING.md

    This button will cause a Javascript alert dialog to appear asking you to type a reason for accepting the changes, e.g. "Added new API for Gradle 8.x".
    
    Clicking okay on the dialog will cause a copy of the `accepted-public-api-changes.json` containing your (properly sorted) addition to be downloaded.
    You can then replace the existing file with this new downloaded version. 
    ### Java Toolchain
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Nov 05 15:15:33 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/collect/testing/google/MultisetFeature.java

    @GwtCompatible
    public enum MultisetFeature implements Feature<Multiset> {
      /**
       * Indicates that elements from {@code Multiset.entrySet()} update to reflect changes in the
       * backing multiset.
       */
      ENTRIES_ARE_VIEWS;
    
      @Override
      public Set<Feature<? super Multiset>> getImpliedFeatures() {
        return emptySet();
      }
    
      @Retention(RetentionPolicy.RUNTIME)
      @Inherited
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  7. guava-testlib/src/com/google/common/collect/testing/google/MultisetFeature.java

    @GwtCompatible
    public enum MultisetFeature implements Feature<Multiset> {
      /**
       * Indicates that elements from {@code Multiset.entrySet()} update to reflect changes in the
       * backing multiset.
       */
      ENTRIES_ARE_VIEWS;
    
      @Override
      public Set<Feature<? super Multiset>> getImpliedFeatures() {
        return emptySet();
      }
    
      @Retention(RetentionPolicy.RUNTIME)
      @Inherited
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java

       * backing map.
       *
       * <p>This instance will assume ownership of {@code countMap}, and other code should not maintain
       * references to the map or modify it in any way.
       *
       * <p>The returned multiset is serializable if the input map is.
       *
       * @param countMap backing map for storing the elements in the multiset and their counts. It must
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  9. common/scripts/setup_env.sh

    #!/usr/bin/env bash
    # shellcheck disable=SC2034
    
    # WARNING: DO NOT EDIT, THIS FILE IS PROBABLY A COPY
    #
    # The original version of this file is located in the https://github.com/istio/common-files repo.
    # If you're looking at this file in a different repo and want to make a change, please go to the
    # common-files repo, make the change there and check it in. Then come back to this repo and run
    # "make update-common".
    
    # Copyright Istio Authors
    #
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 06 04:52:54 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java

                    }
                  });
          assertEquals("Counts not as expected", Ints.asList(deltas), actualCounts);
        } finally {
          pool.shutdownNow();
        }
    
        // Since we have access to the backing map, verify that there are no zeroes in the map
        for (AtomicInteger value : map.values()) {
          assertTrue("map should not contain a zero", value.get() != 0);
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 5.9K bytes
    - Viewed (0)
Back to top