Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for yielding (0.14 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

     * [advanceUntil]. These functions don't return until the task threads are all idle.
     *
     * Task threads release their execution privilege in these ways:
     *
     *  * By yielding in [TaskRunner.Backend.coordinatorWait].
     *  * By yielding in [BlockingQueue.poll].
     *  * By completing.
     */
    class TaskFaker : Closeable {
      @Suppress("NOTHING_TO_INLINE")
      internal inline fun Any.assertThreadHoldsLock() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/net/HostAndPortTest.java

        } catch (IllegalArgumentException e) {
          // Make sure we expected this.
          assertNull(expectHost);
          return;
        }
        assertNotNull(expectHost);
    
        // Apply withDefaultPort(), yielding hp2.
        final boolean badDefaultPort = (defaultPort < 0 || defaultPort > 65535);
        HostAndPort hp2 = null;
        try {
          hp2 = hp.withDefaultPort(defaultPort);
          assertFalse(badDefaultPort);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  3. src/cmd/asm/internal/asm/parse.go

    // static or a particular ABI specification.
    //
    // The expected form of the attribute clause is:
    //
    // empty,           yielding (false, obj.ABI0)
    // "<>",            yielding (true,  obj.ABI0)
    // "<ABI0>"         yielding (false, obj.ABI0)
    // "<ABIInternal>"  yielding (false, obj.ABIInternal)
    //
    // Anything else beginning with "<" logs an error if issueError is
    // true, otherwise returns (false, obj.ABI0).
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        /*
         * Wait not just until the Future's value is set (as in future.get()) but
         * also until ListeningScheduledExecutorService's wrapper task is done
         * executing listeners, as detected by yielding control to afterExecute.
         */
        completed.await();
        assertTrue(future.isDone());
        assertThat(future.get()).isEqualTo(42);
        assertListenerRunImmediately(future);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/hash/BloomFilter.java

      @Override
      public int hashCode() {
        return Objects.hashCode(numHashFunctions, funnel, strategy, bits);
      }
    
      /**
       * Returns a {@code Collector} expecting the specified number of insertions, and yielding a {@link
       * BloomFilter} with false positive probability 3%.
       *
       * <p>Note that if the {@code Collector} receives significantly more elements than specified, the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 23 16:45:30 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        /*
         * Wait not just until the Future's value is set (as in future.get()) but
         * also until ListeningScheduledExecutorService's wrapper task is done
         * executing listeners, as detected by yielding control to afterExecute.
         */
        completed.await();
        assertTrue(future.isDone());
        assertThat(future.get()).isEqualTo(42);
        assertListenerRunImmediately(future);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/FluentIterable.java

       * specified function to each item in this {@code FluentIterable} of values. Each element of this
       * iterable will be stored as a value in the resulting multimap, yielding a multimap with the same
       * size as this iterable. The key used to store that value in the multimap will be the result of
       * calling the function on that value. The resulting multimap is created as an immutable snapshot.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Sep 24 13:42:31 UTC 2024
    - 35.7K bytes
    - Viewed (0)
  8. src/bytes/bytes.go

    }
    
    // Replace returns a copy of the slice s with the first n
    // non-overlapping instances of old replaced by new.
    // If old is empty, it matches at the beginning of the slice
    // and after each UTF-8 sequence, yielding up to k+1 replacements
    // for a k-rune slice.
    // If n < 0, there is no limit on the number of replacements.
    func Replace(s, old, new []byte, n int) []byte {
    	m := 0
    	if n != 0 {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 35.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/Multimaps.java

       * Creates an index {@code ImmutableListMultimap} that contains the results of applying a
       * specified function to each item in an {@code Iterable} of values. Each value will be stored as
       * a value in the resulting multimap, yielding a multimap with the same size as the input
       * iterable. The key used to store that value in the multimap will be the result of calling the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  10. cmd/xl-storage-disk-id-check.go

    			a.N = atomic.LoadInt64(&old.N)
    			e.mu.Lock()
    			e.lastMinuteLatency.addAll(t-1, a)
    			e.mu.Unlock()
    			acc = newAcc
    		} else {
    			// We may be able to grab the new accumulator by yielding.
    			runtime.Gosched()
    			acc = e.cached.Load()
    		}
    	}
    	atomic.AddInt64(&acc.N, 1)
    	atomic.AddInt64(&acc.Total, int64(value))
    	atomic.AddInt64(&acc.Size, sz)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
Back to top