Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for currentThread (0.14 sec)

  1. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 17:02:07 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  2. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 17:02:07 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        assertFalse(Thread.currentThread().isInterrupted());
        assertFalse(monitor.isOccupiedByCurrentThread());
    
        doEnterScenarioSetUp();
    
        boolean interruptedBeforeCall = Thread.currentThread().isInterrupted();
        Outcome actualOutcome = doCall();
        boolean occupiedAfterCall = monitor.isOccupiedByCurrentThread();
        boolean interruptedAfterCall = Thread.currentThread().isInterrupted();
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 27.1K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        String oldName = Thread.currentThread().getName();
        renamingExecutor.execute(
            new Runnable() {
              @Override
              public void run() {
                assertEquals("FooBar", Thread.currentThread().getName());
              }
            });
        assertEquals(oldName, Thread.currentThread().getName());
      }
    
      public void testExecutors_nullCheck() throws Exception {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  5. impl/maven-core/src/main/java/org/apache/maven/plugin/internal/DefaultMavenPluginManager.java

            ClassRealm oldLookupRealm = container.setLookupRealm(pluginRealm);
    
            ClassLoader oldClassLoader = Thread.currentThread().getContextClassLoader();
            Thread.currentThread().setContextClassLoader(pluginRealm);
    
            try {
                if (mojoDescriptor.isV4Api()) {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Dec 09 16:35:21 UTC 2025
    - 46.4K bytes
    - Viewed (0)
  6. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/storage/StorageClientTest.java

                    org.codelibs.core.timer.TimeoutTask accessTimeoutTask = null;
                    if (accessTimeout != null) {
                        accessTimeoutTarget = new org.codelibs.fess.crawler.client.AccessTimeoutTarget(Thread.currentThread());
                        accessTimeoutTask = org.codelibs.core.timer.TimeoutManager.getInstance()
                                .addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
                    }
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        String oldName = Thread.currentThread().getName();
        renamingExecutor.execute(
            new Runnable() {
              @Override
              public void run() {
                assertEquals("FooBar", Thread.currentThread().getName());
              }
            });
        assertEquals(oldName, Thread.currentThread().getName());
      }
    
      public void testExecutors_nullCheck() throws Exception {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  8. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/s3/S3ClientTest.java

                    org.codelibs.core.timer.TimeoutTask accessTimeoutTask = null;
                    if (accessTimeout != null) {
                        accessTimeoutTarget = new org.codelibs.fess.crawler.client.AccessTimeoutTarget(Thread.currentThread());
                        accessTimeoutTask = org.codelibs.core.timer.TimeoutManager.getInstance()
                                .addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
                    }
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 07:57:44 UTC 2025
    - 20.5K bytes
    - Viewed (0)
  9. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/gcs/GcsClientTest.java

                    org.codelibs.core.timer.TimeoutTask accessTimeoutTask = null;
                    if (accessTimeout != null) {
                        accessTimeoutTarget = new org.codelibs.fess.crawler.client.AccessTimeoutTarget(Thread.currentThread());
                        accessTimeoutTask = org.codelibs.core.timer.TimeoutManager.getInstance()
                                .addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
                    }
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 19.6K bytes
    - Viewed (0)
  10. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                    try {
                        Thread.sleep(50);
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                        break;
                    }
                }
                assertEquals(CrawlerStatus.RUNNING, crawler.crawlerContext.getStatus());
                crawler.awaitTermination();
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Tue Nov 11 13:40:14 UTC 2025
    - 25.8K bytes
    - Viewed (0)
Back to top