Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 611 for thread_ (0.05 sec)

  1. 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)
  2. 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)
  3. docs/changelogs/changelog_3x.md

        hand it off to another thread to write to it after `writeTo` returns.
    
        The `EventListener` may now see requests and responses interleaved in ways not previously
        permitted. For example, a listener may receive `responseHeadersStart()` followed by
        `requestBodyEnd()`, both on the same call. Such events may be triggered by different threads
        even for a single call.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  4. 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)
  5. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

      private fun sleep(delayMillis: Int) {
        try {
          Thread.sleep(delayMillis.toLong())
        } catch (e: InterruptedException) {
          Thread.currentThread().interrupt()
        }
      }
    
      private fun cancelLater(
        call: Call,
        delayMillis: Int,
      ): CountDownLatch {
        val latch = CountDownLatch(1)
        Thread {
          sleep(delayMillis)
          if (cancelMode == CANCEL) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

                return jvmGcObj;
            }).toArray(n -> new JvmGcObj[n]);
            final Threads threads = jvmStats.getThreads();
            final JvmThreadsObj jvmThreadsObj = new JvmThreadsObj();
            jvmObj.threads = jvmThreadsObj;
            jvmThreadsObj.count = threads.getCount();
            jvmThreadsObj.peak = threads.getPeakCount();
            final Classes classes = jvmStats.getClasses();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  7. 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)
  8. 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/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)
  10. guava/src/com/google/common/cache/CacheBuilder.java

       * accommodate as many threads as will ever concurrently modify the table. Using a significantly
       * higher value than you need can waste space and time, and a significantly lower value can lead
       * to thread contention. But overestimates and underestimates within an order of magnitude do not
       * usually have much noticeable impact. A value of one permits only one thread to modify the cache
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 51.6K bytes
    - Viewed (0)
Back to top