Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 271 - 280 of 2,462 for wong (0.02 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        SettableFuture<Long> future1 = SettableFuture.create();
        SettableFuture<Long> future2 = SettableFuture.create();
        SettableFuture<Long> future3 = SettableFuture.create();
        SettableFuture<Long> future4 = SettableFuture.create();
        SettableFuture<Long> future5 = SettableFuture.create();
    
        ImmutableList<ListenableFuture<Long>> futures =
            inCompletionOrder(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        SettableFuture<Long> future1 = SettableFuture.create();
        SettableFuture<Long> future2 = SettableFuture.create();
        SettableFuture<Long> future3 = SettableFuture.create();
        SettableFuture<Long> future4 = SettableFuture.create();
        SettableFuture<Long> future5 = SettableFuture.create();
    
        ImmutableList<ListenableFuture<Long>> futures =
            inCompletionOrder(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

       *
       * TODO: make this inline once this is fixed: https://github.com/oracle/graal/issues/3466
       */
      fun schedule(
        name: String,
        delayNanos: Long = 0L,
        block: () -> Long,
      ) {
        schedule(
          object : Task(name) {
            override fun runOnce(): Long = block()
          },
          delayNanos,
        )
      }
    
      /**
       * Executes [block] once on a task runner thread.
       *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/math/BigIntegerMath.java

        int approxSize = IntMath.divide(n * IntMath.log2(n, CEILING), Long.SIZE, CEILING);
        ArrayList<BigInteger> bignums = new ArrayList<>(approxSize);
    
        // Start from the pre-computed maximum long factorial.
        int startingNumber = LongMath.factorials.length;
        long product = LongMath.factorials[startingNumber - 1];
        // Strip off 2s from this value.
        int shift = Long.numberOfTrailingZeros(product);
        product >>= shift;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 18.8K bytes
    - Click Count (0)
  5. benchmarks/src/main/java/org/elasticsearch/benchmark/indices/breaker/MemoryStatsBenchmark.java

        @Threads(4)
        public long getMemoryStats_04() {
            Blackhole.consumeCPU(tokens);
            return MEMORY_MX_BEAN.getHeapMemoryUsage().getUsed();
        }
    
        @Benchmark
        @Threads(8)
        public long getMemoryStats_08() {
            Blackhole.consumeCPU(tokens);
            return MEMORY_MX_BEAN.getHeapMemoryUsage().getUsed();
        }
    
        @Benchmark
        @Threads(16)
        public long getMemoryStats_16() {
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Feb 03 00:10:53 GMT 2021
    - 2.7K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/opensearch/config/cbean/cq/bs/BsCrawlingInfoParamCQ.java

            return this;
        }
    
        public void setCreatedTime_Equal(Long createdTime) {
            setCreatedTime_Term(createdTime, null);
        }
    
        public void setCreatedTime_Equal(Long createdTime, ConditionOptionCall<TermQueryBuilder> opLambda) {
            setCreatedTime_Term(createdTime, opLambda);
        }
    
        public void setCreatedTime_Term(Long createdTime) {
            setCreatedTime_Term(createdTime, null);
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 36K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/collect/Internal.java

       *
       * <p>Instead of throwing {@link ArithmeticException}, this method silently saturates to either
       * {@link Long#MAX_VALUE} or {@link Long#MIN_VALUE}. This behavior can be useful when decomposing
       * a duration in order to call a legacy API which requires a {@code long, TimeUnit} pair.
       */
      static long toNanosSaturated(Duration duration) {
        // Using a try/catch seems lazy, but the catch block will rarely get invoked (except for
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Nov 04 17:24:58 GMT 2025
    - 1.8K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

        ArrayList<Future<Long>> futures = new ArrayList<>();
        for (int i = 0; i < nTasks; i++) {
          futures.add(
              threadPool.submit(
                  new Callable<Long>() {
                    @Override
                    public Long call() {
                      long threadSum = 0;
                      for (int j = 0; j < getsPerTask; j++) {
                        long delta = random.nextInt(deltaRange);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      private inner class FixedLengthSource(
        url: HttpUrl,
        private var bytesRemaining: Long,
      ) : AbstractSource(url) {
        init {
          if (bytesRemaining == 0L) {
            responseBodyComplete(trailers = Headers.EMPTY)
          }
        }
    
        override fun read(
          sink: Buffer,
          byteCount: Long,
        ): Long {
          require(byteCount >= 0L) { "byteCount < 0: $byteCount" }
          check(!closed) { "closed" }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 17.6K bytes
    - Click Count (7)
  10. src/test/java/jcifs/SmbFileHandleTest.java

        }
    
        /**
         * Test close(long) successfully.
         *
         * @throws CIFSException
         */
        @Test
        void testCloseWithLastWriteTime_success() throws CIFSException {
            long lastWriteTime = System.currentTimeMillis();
            smbFileHandle.close(lastWriteTime);
            verify(smbFileHandle, times(1)).close(lastWriteTime);
        }
    
        /**
         * Test close(long) when a CIFSException is thrown.
         *
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.1K bytes
    - Click Count (0)
Back to Top