Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for joinUninterruptibly (0.08 sec)

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

        Thread thread = new Thread(new JoinTarget(15));
        thread.start();
        thread.join();
        assertFalse(thread.isAlive());
    
        joinUninterruptibly(thread);
        joinUninterruptibly(thread, 0, MILLISECONDS);
        joinUninterruptibly(thread, -42, MILLISECONDS);
        joinUninterruptibly(thread, LONG_DELAY_MS, MILLISECONDS);
        assertTimeNotPassed(stopwatch, LONG_DELAY_MS);
      }
    
      public void testJoinNoInterrupt() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 31.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

            new TearDown() {
              @Override
              public void tearDown() throws Exception {
                interruptingTask.stopInterrupting();
                interruptingThread.interrupt();
                joinUninterruptibly(interruptingThread, 2500, MILLISECONDS);
                Thread.interrupted();
                if (interruptingThread.isAlive()) {
                  // This will be hidden by test-output redirection:
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

            new TearDown() {
              @Override
              public void tearDown() throws Exception {
                interruptingTask.stopInterrupting();
                interruptingThread.interrupt();
                joinUninterruptibly(interruptingThread, 2500, MILLISECONDS);
                Thread.interrupted();
                if (interruptingThread.isAlive()) {
                  // This will be hidden by test-output redirection:
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      @IgnoreJRERequirement // Users will use this only if they're already using Duration.
      public static void joinUninterruptibly(Thread toJoin, Duration timeout) {
        joinUninterruptibly(toJoin, toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    
      /**
       * Invokes {@code unit.}{@link TimeUnit#timedJoin(Thread, long) timedJoin(toJoin, timeout)}
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/hash/BloomFilterTest.java

                }
              });
          threads.add(thread);
        }
        for (Thread t : threads) {
          t.start();
        }
        for (Thread t : threads) {
          Uninterruptibles.joinUninterruptibly(t);
        }
        return exceptions;
      }
    
      private static int getNonGoldenRandomKey() {
        int key;
        do {
          key = random.get().nextInt();
        } while (key == GOLDEN_PRESENT_KEY);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 22K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/hash/BloomFilterTest.java

                }
              });
          threads.add(thread);
        }
        for (Thread t : threads) {
          t.start();
        }
        for (Thread t : threads) {
          Uninterruptibles.joinUninterruptibly(t);
        }
        return exceptions;
      }
    
      private static int getNonGoldenRandomKey() {
        int key;
        do {
          key = random.get().nextInt();
        } while (key == GOLDEN_PRESENT_KEY);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 22K bytes
    - Viewed (0)
Back to top