Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for CountDown (0.57 sec)

  1. src/test/java/jcifs/smb/SmbSessionImplSecurityTest.java

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

            TrustedListenableFutureTask.create(
                new Callable<Integer>() {
                  @Override
                  public Integer call() throws Exception {
                    enterLatch.countDown();
                    try {
                      new CountDownLatch(1).await(); // wait forever
                      throw new AssertionError();
                    } catch (InterruptedException e) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/cache/CacheLoadingTest.java

            cache.getUnchecked(getKey);
            getFinishedSignal.countDown();
          }
        }.start();
        new Thread() {
          @Override
          public void run() {
            cache.refresh(refreshKey);
            getFinishedSignal.countDown();
          }
        }.start();
    
        // let computation complete
        letGetFinishSignal.countDown();
        getFinishedSignal.await();
        checkNothingLogged();
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 85.7K bytes
    - Viewed (0)
  4. src/test/java/jcifs/internal/smb2/ServerMessageBlock2ResponseTest.java

                            startLatch.await();
                            response.received();
                            endLatch.countDown();
                        } catch (InterruptedException e) {
                            // Ignore
                        }
                    }).start();
                }
    
                startLatch.countDown();
                assertTrue(endLatch.await(1, TimeUnit.SECONDS));
                assertTrue(response.isReceived());
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb/NtlmPasswordAuthenticatorTest.java

                        fail("Unexpected exception: " + e.getMessage());
                    } finally {
                        completeLatch.countDown();
                    }
                }).start();
            }
    
            // Start all threads simultaneously
            startLatch.countDown();
    
            // Wait for completion
            assertTrue(completeLatch.await(5, TimeUnit.SECONDS));
    
            // Authenticator should be closed
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 23.3K bytes
    - Viewed (0)
  6. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java

                            Thread.currentThread().interrupt();
                        } finally {
                            endLatch.countDown();
                        }
                    }
                });
            }
    
            startLatch.countDown();
            endLatch.await(10, TimeUnit.SECONDS);
            executor.shutdown();
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  7. src/test/java/jcifs/smb/CriticalPerformanceTest.java

                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                    } finally {
                        endLatch.countDown();
                    }
                });
            }
    
            startLatch.countDown(); // Start all threads
            assertTrue(endLatch.await(30, TimeUnit.SECONDS), "All threads should complete within timeout");
            executor.shutdown();
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  8. src/test/java/jcifs/util/SmbCircuitBreakerTest.java

                                rejectedCount.incrementAndGet();
                            }
                        } finally {
                            completeLatch.countDown();
                        }
                    });
                }
    
                startLatch.countDown();
                assertTrue(completeLatch.await(5, TimeUnit.SECONDS), "All tasks should complete");
                executor.shutdown();
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 23.2K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/PreauthIntegrityTest.java

                        fail("Thread failed: " + e.getMessage());
                    } finally {
                        doneLatch.countDown();
                    }
                });
            }
    
            // Start all threads at once
            startLatch.countDown();
    
            // Wait for completion
            assertTrue(doneLatch.await(5, TimeUnit.SECONDS), "Threads did not complete in time");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  10. mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt

            } finally {
              closedLatch.countDown()
            }
          }
        }.buffer()
    
      override val sink: BufferedSink =
        object : ForwardingSink(delegate.sink) {
          private var closed = false
    
          override fun close() {
            if (closed) return
            try {
              super.close()
            } finally {
              closedLatch.countDown()
            }
          }
        }.buffer()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 3.3K bytes
    - Viewed (0)
Back to top