Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 247 for InterruptedException (0.08 sec)

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

        verifyTimedGetOnPendingFuture(future);
      }
    
      private static void assertSuccessful(
          AbstractFuture<Integer> future, @Nullable Integer expectedResult)
          throws InterruptedException, TimeoutException, ExecutionException {
        assertDone(future);
        assertThat(future.isCancelled()).isFalse();
    
        assertThat(getDone(future)).isEqualTo(expectedResult);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/TestThread.java

            }
            responseQueue.put(new Response(request.methodName, result, null));
          }
        } catch (ThreadDeath death) {
          return;
        } catch (InterruptedException ignored) {
          // SynchronousQueue sometimes throws InterruptedException while the threads are stopping.
        } catch (Throwable uncaught) {
          this.uncaughtThrowable = uncaught;
        }
      }
    
      private static class Request {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  3. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

              }
            });
        assertTrue(map.isEmpty());
      }
    
      // ----------------------------------------------------------------
      // Test that interrupts result in RuntimeException, not InterruptedException.
      // Trickier than it looks, because runFinalization swallows interrupts.
      // ----------------------------------------------------------------
    
      class Interruptenator extends Thread {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        return method.getReturnType() == boolean.class;
      }
    
      /** Determines whether the given method can throw InterruptedException. */
      private static boolean isInterruptible(Method method) {
        return Arrays.asList(method.getExceptionTypes()).contains(InterruptedException.class);
      }
    
      /** Sorts the given methods primarily by name and secondarily by number of parameters. */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 27K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

            finishLatch.await(1, MINUTES);
          } catch (InterruptedException e) {
            fail(e.toString());
          } finally {
            lock.unlock();
          }
        }
    
        void waitUntilHoldingLock() throws InterruptedException {
          locked.await(1, MINUTES);
        }
    
        void releaseLockAndFinish() throws InterruptedException {
          finishLatch.countDown();
          this.join(10000);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

            finishLatch.await(1, MINUTES);
          } catch (InterruptedException e) {
            fail(e.toString());
          } finally {
            lock.unlock();
          }
        }
    
        void waitUntilHoldingLock() throws InterruptedException {
          locked.await(1, MINUTES);
        }
    
        void releaseLockAndFinish() throws InterruptedException {
          finishLatch.countDown();
          this.join(10000);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        private volatile boolean running = false;
    
        @Override
        public @Nullable Void call() throws InterruptedException {
          running = true;
          startLatch.countDown();
          stopLatch.await();
          running = false;
          return null;
        }
    
        void waitForStart() throws InterruptedException {
          startLatch.await();
        }
    
        void stop() {
          stopLatch.countDown();
        }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 20:58:01 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/rdma/RdmaErrorHandler.java

                        log.info("RDMA connection recovery successful after {} attempts", retryCount);
                        return true;
                    }
    
                } catch (InterruptedException e) {
                    log.debug("RDMA recovery interrupted");
                    Thread.currentThread().interrupt();
                    break;
                } catch (Exception recoveryError) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  9. src/main/java/jcifs/netbios/NameServiceClientImpl.java

                    return null;
                }
                while (this.inFlightLookups.contains(name)) {
                    try {
                        this.inFlightLookups.wait();
                    } catch (final InterruptedException e) {
                        log.trace("Interrupted", e);
                    }
                }
            }
            obj = getCachedAddress(name);
            if (obj == null) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 38.5K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

      public void testSuccess() throws ExecutionException, InterruptedException {
        Object value = new Object();
        assertSame(
            value,
            new AbstractFuture<Object>() {
              {
                set(value);
              }
            }.get());
      }
    
      public void testException() throws InterruptedException {
        Throwable failure = new Throwable();
        AbstractFuture<String> future =
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
Back to top