Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 94 for CountDown (0.06 sec)

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

        return new ListenerCallQueue.Event<Object>() {
          @Override
          public void call(Object listener) {
            latch.countDown();
          }
    
          @Override
          public String toString() {
            return "countDown";
          }
        };
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  2. src/test/java/jcifs/smb1/smb1/BufferCacheSecurityTest.java

                            exceptions.add(e);
                        }
                    } finally {
                        endLatch.countDown();
                    }
                });
            }
    
            // Start all threads
            startLatch.countDown();
    
            // Wait for completion
            assertTrue(endLatch.await(30, TimeUnit.SECONDS), "All threads should complete");
            executor.shutdown();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

              outputFuture.set(RESULT_DATA);
              break;
            case SLOW_OUTPUT_VALID_INPUT_DATA:
              break; // do nothing to the result
            case SLOW_FUNC_VALID_INPUT_DATA:
              funcIsWaitingLatch.countDown();
              awaitUninterruptibly(funcCompletionLatch);
              break;
            case EXCEPTION_DATA:
              throw EXCEPTION;
          }
          return outputFuture;
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

              outputFuture.set(RESULT_DATA);
              break;
            case SLOW_OUTPUT_VALID_INPUT_DATA:
              break; // do nothing to the result
            case SLOW_FUNC_VALID_INPUT_DATA:
              funcIsWaitingLatch.countDown();
              awaitUninterruptibly(funcCompletionLatch);
              break;
            case EXCEPTION_DATA:
              throw EXCEPTION;
          }
          return outputFuture;
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt

              latch2.countDown()
            }
          }
        val request2Listener: EventListener =
          object : EventListener() {
            override fun connectStart(
              call: Call,
              inetSocketAddress: InetSocketAddress,
              proxy: Proxy,
            ) {
              // Let request1 proceed to make a connection.
              latch1.countDown()
              try {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jun 19 11:44:16 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

                    } catch (final Exception e) {
                        logger.warn("Could not close a process input stream.", e);
                    } finally {
                        latch.countDown();
                    }
                }, "ProcessCloser-input-" + sessionId).start();
                new Thread(() -> {
                    try {
                        CloseableUtil.closeQuietly(process.getErrorStream());
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

          arguments.add(Duration.ofMillis(timeout.millis));
        }
        try {
          Object result;
          doingCallLatch.countDown();
          try {
            result = method.invoke(monitor, arguments.toArray());
          } finally {
            callCompletedLatch.countDown();
          }
          if (result == null) {
            return Outcome.SUCCESS;
          } else if ((Boolean) result) {
            return Outcome.SUCCESS;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 27K bytes
    - Viewed (0)
  8. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

        Object unused =
            new Object() {
              @SuppressWarnings({"removal", "Finalize"}) // b/260137033
              @Override
              protected void finalize() {
                latch.countDown();
              }
            };
        unused = null; // Hint to the JIT that unused is unreachable
        GcFinalization.await(latch);
        assertEquals(0, latch.getCount());
      }
    
      public void testAwaitDone_future() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

                    computationStarted.countDown();
                    cache.getUnchecked("b");
                    computationComplete.countDown();
                  }
                })
            .start();
    
        // wait for the computingEntry to be created
        computationStarted.await();
        cache.invalidateAll();
        // let the computation proceed
        computingLatch.countDown();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 25.1K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

                    computationStarted.countDown();
                    cache.getUnchecked("b");
                    computationComplete.countDown();
                  }
                })
            .start();
    
        // wait for the computingEntry to be created
        computationStarted.await();
        cache.invalidateAll();
        // let the computation proceed
        computingLatch.countDown();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 25K bytes
    - Viewed (0)
Back to top