Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 42 for currentThread (0.62 seconds)

  1. 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;
              }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  2. 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);
          }
        }
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Jul 23 00:58:06 GMT 2025
    - 5K bytes
    - Click Count (0)
  3. 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);
        }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 6.9K bytes
    - Click Count (0)
  4. 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));
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Dec 08 17:02:07 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  5. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/PlexusContainerCapsule.java

            return Optional.of(plexusContainer.getContainerRealm());
        }
    
        @Override
        public void close() {
            try {
                plexusContainer.dispose();
            } finally {
                Thread.currentThread().setContextClassLoader(previousClassLoader);
            }
        }
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Mar 24 14:09:05 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  6. 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));
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Dec 08 17:02:07 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  7. 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);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Aug 10 19:54:19 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  8. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/BuildListCalculator.java

                } else {
                    projects = session.getProjects();
                }
                for (MavenProject project : projects) {
                    ClassLoader tccl = Thread.currentThread().getContextClassLoader();
                    MavenProject currentProject = session.getCurrentProject();
                    try {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 2.6K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/Platform.java

      static void restoreInterruptIfIsInterruptedException(Throwable t) {
        checkNotNull(t); // to satisfy NullPointerTester
        if (t instanceof InterruptedException) {
          currentThread().interrupt();
        }
      }
    
      static void interruptCurrentThread() {
        Thread.currentThread().interrupt();
      }
    
      static void rethrowIfErrorOtherThanStackOverflow(Throwable t) {
        checkNotNull(t);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  10. guava/src/com/google/common/util/concurrent/Platform.java

      static void restoreInterruptIfIsInterruptedException(Throwable t) {
        checkNotNull(t); // to satisfy NullPointerTester
        if (t instanceof InterruptedException) {
          currentThread().interrupt();
        }
      }
    
      static void interruptCurrentThread() {
        Thread.currentThread().interrupt();
      }
    
      static void rethrowIfErrorOtherThanStackOverflow(Throwable t) {
        checkNotNull(t);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 2.1K bytes
    - Click Count (0)
Back to Top