Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for currentThread (0.22 sec)

  1. src/test/java/jcifs/tests/persistent/HandleInfoTest.java

                    null);
    
            assertFalse(durableInfo.isExpired());
    
            // Wait for expiration
            try {
                Thread.sleep(150);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
    
            assertTrue(durableInfo.isExpired());
    
            // Test persistent handle (never expires)
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

      public void testRenaming() throws Exception {
        String oldName = Thread.currentThread().getName();
        Supplier<String> newName = Suppliers.ofInstance("MyCrazyThreadName");
        Callable<@Nullable Void> callable =
            new Callable<@Nullable Void>() {
              @Override
              public @Nullable Void call() throws Exception {
                assertEquals(Thread.currentThread().getName(), newName.get());
                return null;
              }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/core/concurrent/CommonPoolUtil.java

         */
        public static void execute(final Runnable task) {
            ForkJoinPool.commonPool().execute(() -> {
                final Thread currentThread = Thread.currentThread();
                final ClassLoader orignal = currentThread.getContextClassLoader();
                currentThread.setContextClassLoader(CommonPoolUtil.class.getClassLoader());
                try {
                    task.run();
                } catch (final Exception e) {
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

                    }
                    return toReturn;
                  }
                }
                return super.loadClass(name);
              }
            };
        oldClassLoader = Thread.currentThread().getContextClassLoader();
        Thread.currentThread().setContextClassLoader(classReloader);
        abstractFutureClass = classReloader.loadClass(AbstractFuture.class.getName());
        settableFutureClass = classReloader.loadClass(SettableFuture.class.getName());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

                    }
                    return toReturn;
                  }
                }
                return super.loadClass(name);
              }
            };
        oldClassLoader = Thread.currentThread().getContextClassLoader();
        Thread.currentThread().setContextClassLoader(classReloader);
        abstractFutureClass = classReloader.loadClass(AbstractFuture.class.getName());
        settableFutureClass = classReloader.loadClass(SettableFuture.class.getName());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Lockable.kt

      if (assertionsEnabled && Thread.holdsLock(this)) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST NOT hold lock on $this")
      }
    }
    
    internal inline fun Lockable.assertLockHeld() {
      if (assertionsEnabled && !Thread.holdsLock(this)) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
      }
    }
    
    @OptIn(ExperimentalContracts::class)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  7. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

        assertThat(e).hasCauseThat().isInstanceOf(InterruptedException.class);
      }
    
      public void testAwait_countDownLatch_interrupted() {
        Interruptenator interruptenator = new Interruptenator(Thread.currentThread());
        try {
          CountDownLatch latch = new CountDownLatch(1);
          RuntimeException expected =
              assertThrows(RuntimeException.class, () -> GcFinalization.await(latch));
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  8. samples/crawler/src/main/java/okhttp3/sample/Crawler.java

            continue;
          }
    
          Thread currentThread = Thread.currentThread();
          String originalName = currentThread.getName();
          currentThread.setName("Crawler " + url);
          try {
            fetch(url);
          } catch (IOException e) {
            System.out.printf("XXX: %s %s%n", url, e);
          } finally {
            currentThread.setName(originalName);
          }
        }
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jul 23 00:58:06 UTC 2025
    - 5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/io/ResourcesTest.java

        ClassLoader oldContextLoader = Thread.currentThread().getContextClassLoader();
        try {
          Thread.currentThread().setContextClassLoader(loader);
          URL url = Resources.getResource(tempFile.getName());
          String text = Resources.toString(url, UTF_8);
          assertEquals("rud a chur ar an méar fhada" + System.lineSeparator(), text);
        } finally {
          Thread.currentThread().setContextClassLoader(oldContextLoader);
        }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed May 14 19:40:47 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

        }
      }
    
      /** Interrupts the current thread after sleeping for the specified delay. */
      static void requestInterruptIn(long time, TimeUnit unit) {
        checkNotNull(unit);
        Thread interruptee = Thread.currentThread();
        new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
                      unit.sleep(time);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
Back to top