- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 42 for currentThread (0.62 seconds)
-
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) -
samples/crawler/src/main/java/okhttp3/sample/Crawler.java
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Jul 23 00:58:06 GMT 2025 - 5K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)