Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 614 for threads (0.07 sec)

  1. guava/src/com/google/common/collect/ForwardingList.java

     * invoke methods, they invoke methods on the {@code ForwardingList}.
     *
     * <p>The {@code standard} methods and any collection views they return are not guaranteed to be
     * thread-safe, even when all of the methods that they depend on are thread-safe.
     *
     * @author Mike Bostock
     * @author Louis Wasserman
     * @since 2.0
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 15:26:39 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/collect/QueuesTest.java

          }
        }
      }
    
      private static class Interrupter implements Runnable {
        final Thread threadToInterrupt;
    
        Interrupter(Thread threadToInterrupt) {
          this.threadToInterrupt = threadToInterrupt;
        }
    
        @Override
        public void run() {
          try {
            Thread.sleep(100);
          } catch (InterruptedException e) {
            throw new AssertionError();
          } finally {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/test/kotlin/okhttp3/OkHttpClientTestRuleTest.kt

        }
    
      @Test fun uncaughtException() {
        val testRule = OkHttpClientTestRule()
        testRule.beforeEach(extensionContext)
    
        val thread =
          object : Thread() {
            override fun run() {
              throw RuntimeException("boom!")
            }
          }
        thread.start()
        thread.join()
    
        assertFailsWith<AssertionError> {
          testRule.afterEach(extensionContext)
        }.also { expected ->
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/TimeLimiter.java

       * The particular nature and strength of the guarantees made by the proxy is
       * implementation-dependent. However, it is important that each of the methods on the target
       * object behaves appropriately when its thread is interrupted.
       *
       * <p>For example, to return the value of {@code target.someMethod()}, but substitute {@code
       * DEFAULT_VALUE} if this method call takes over 50 ms, you can use this code:
       *
       * <pre>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        final CountDownLatch doneSignal = new CountDownLatch(1);
    
        Thread thread =
            new Thread() {
              @Override
              public void run() {
                try {
                  cacheRef.get().getUnchecked(3);
                } finally {
                  doneSignal.countDown();
                }
              }
            };
        thread.setUncaughtExceptionHandler(
            new UncaughtExceptionHandler() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        final CountDownLatch doneSignal = new CountDownLatch(1);
    
        Thread thread =
            new Thread() {
              @Override
              public void run() {
                try {
                  cacheRef.get().getUnchecked(3);
                } finally {
                  doneSignal.countDown();
                }
              }
            };
        thread.setUncaughtExceptionHandler(
            new UncaughtExceptionHandler() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  7. src/main/java/jcifs/netbios/NameServiceClientImpl.java

        }
    
    
        private static void interruptThreadSafely ( QueryThread thread ) {
            try {
                thread.interrupt();
            }
            catch ( SecurityException e ) {
                e.printStackTrace();
            }
        }
    
    
        private static void joinThread ( Thread thread ) {
            try {
                thread.join();
            }
            catch ( InterruptedException e ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 14 14:26:22 UTC 2022
    - 38.2K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // Thread.interrupt
      public void testGetUnchecked_interrupted() {
        Thread.currentThread().interrupt();
        try {
          assertEquals("foo", getUnchecked(immediateFuture("foo")));
          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // Thread.interrupt
      public void testGetUnchecked_interrupted() {
        Thread.currentThread().interrupt();
        try {
          assertEquals("foo", getUnchecked(immediateFuture("foo")));
          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

        Thread.currentThread().interrupt();
        try {
          getChecked(future, TwoArgConstructorException.class);
          fail();
        } catch (TwoArgConstructorException expected) {
          assertThat(expected).hasCauseThat().isInstanceOf(InterruptedException.class);
          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.3K bytes
    - Viewed (0)
Back to top