Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 127 for recycle (0.11 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

           *
           * Maybe there is a way to avoid this cycle. But we think the cycle is safe enough to ignore:
           * Each task is retained for only as long as it is running -- so it's retained only as long as
           * it would already be retained by the underlying executor.
           *
           * If the cycle test starts reporting this cycle in the future, we should add an entry to
           * cycle_suppress_list.txt.
           */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  2. doc/README.md

    Release notes should be added to `next` by editing existing files or creating
    new files. **Do not add RELNOTE=yes comments in CLs.** Instead, add a file to
    the CL (or ask the author to do so).
    
    At the end of the development cycle, the files will be merged by being
    concatenated in sorted order by pathname. Files in the directory matching the
    glob "*stdlib/*minor" are treated specially. They should be in subdirectories
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Jul 22 17:55:04 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  3. .teamcity/src/main/kotlin/promotion/StartReleaseCycleTest.kt

        init {
            id("Promotion_AllBranchesStartReleaseCycleTest")
            name = "Start Release Cycle Test"
            description = "Test for Start Release Cycle pipeline"
    
            steps {
                gradleWrapper {
                    name = "PromoteTest"
                    tasks = "clean promoteStartReleaseCycle"
                    useGradleWrapper = true
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Dec 05 00:08:14 UTC 2023
    - 2K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt

    import okhttp3.internal.toImmutableList
    
    /**
     * Selects routes to connect to an origin server. Each connection requires a choice of proxy server,
     * IP address, and TLS mode. Connections may also be recycled.
     */
    class RouteSelector(
      private val address: Address,
      private val routeDatabase: RouteDatabase,
      private val connectionUser: ConnectionUser,
      private val fastFallback: Boolean,
    ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Mar 06 17:33:38 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/CharSourceTest.java

      }
    
      public void testConcat_infiniteIterable() throws IOException {
        CharSource source = CharSource.wrap("abcd");
        Iterable<CharSource> cycle = Iterables.cycle(ImmutableList.of(source));
        CharSource concatenated = CharSource.concat(cycle);
    
        String expected = "abcdabcd";
    
        // read the first 8 chars manually, since there's no equivalent to ByteSource.slice
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  6. android/guava-tests/benchmark/com/google/common/util/concurrent/StripedBenchmark.java

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.collect.Iterables.cycle;
    import static com.google.common.collect.Iterables.limit;
    
    import com.google.caliper.BeforeExperiment;
    import com.google.caliper.Benchmark;
    import com.google.caliper.Param;
    import com.google.caliper.api.Footprint;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4K bytes
    - Viewed (0)
  7. guava-tests/benchmark/com/google/common/util/concurrent/StripedBenchmark.java

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.collect.Iterables.cycle;
    import static com.google.common.collect.Iterables.limit;
    
    import com.google.caliper.BeforeExperiment;
    import com.google.caliper.Benchmark;
    import com.google.caliper.Param;
    import com.google.caliper.api.Footprint;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/io/CharSourceTest.java

      }
    
      public void testConcat_infiniteIterable() throws IOException {
        CharSource source = CharSource.wrap("abcd");
        Iterable<CharSource> cycle = Iterables.cycle(ImmutableList.of(source));
        CharSource concatenated = CharSource.concat(cycle);
    
        String expected = "abcdabcd";
    
        // read the first 8 chars manually, since there's no equivalent to ByteSource.slice
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 07 15:26:58 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  9. cmd/callhome.go

    	locker := objAPI.NewNSLock(minioMetaBucket, "callhome/runCallhome.lock")
    	lkctx, err := locker.GetLock(ctx, callhomeLeaderLockTimeout)
    	if err != nil {
    		// lock timedout means some other node is the leader,
    		// cycle back return 'true'
    		return true
    	}
    
    	ctx = lkctx.Context()
    	defer locker.Unlock(lkctx)
    
    	// Perform callhome once and then keep running it at regular intervals.
    	performCallhome(ctx)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/Iterables.java

       * elements.
       *
       * <p>To cycle over the iterable {@code n} times, use the following: {@code
       * Iterables.concat(Collections.nCopies(n, iterable))}
       *
       * <p><b>Java 8+ users:</b> The {@code Stream} equivalent of this method is {@code
       * Stream.generate(() -> iterable).flatMap(Streams::stream)}.
       */
      public static <T extends @Nullable Object> Iterable<T> cycle(final Iterable<T> iterable) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 24 19:38:27 UTC 2024
    - 42.8K bytes
    - Viewed (0)
Back to top