- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 237 for Runnables (0.09 seconds)
-
src/test/java/org/codelibs/fess/app/web/base/FessAdminActionTest.java
public String[] getPermissions() { return permissions; } } private static void assertThrows(final Class<? extends Throwable> expectedType, final Runnable runnable) { try { runnable.run(); throw new AssertionError("Expected " + expectedType.getSimpleName() + " to be thrown"); } catch (final Throwable t) { if (!expectedType.isInstance(t)) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 14:36:23 GMT 2026 - 22.7K bytes - Click Count (0) -
guava/src/com/google/common/base/internal/Finalizer.java
* collected, and this class can detect when the main class loader has been garbage collected and * stop itself. */ public class Finalizer implements Runnable { private static final Logger logger = Logger.getLogger(Finalizer.class.getName()); /** * Starts the Finalizer thread. FinalizableReferenceQueue calls this method reflectively. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 11 03:19:29 GMT 2026 - 9.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt
* This means that if you are doing synchronous calls the network layer will not truly be idle * until every returned [Response] has been closed. */ @get:Synchronized @set:Synchronized var idleCallback: Runnable? = null private var executorServiceOrNull: ExecutorService? = null @get:JvmName("executorService") @get:Synchronized val executorService: ExecutorService get() {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 14:16:22 GMT 2025 - 9.9K bytes - Click Count (0) -
android/guava-testlib/test/com/google/common/collect/testing/MapTestSuiteBuilderTests.java
private static Test testsForSetUpTearDown() { AtomicBoolean setUpRan = new AtomicBoolean(); Runnable setUp = () -> assertFalse("previous tearDown should have run before setUp", setUpRan.getAndSet(true)); Runnable tearDown = () -> assertTrue("setUp should have run", setUpRan.getAndSet(false)); return MapTestSuiteBuilder.using(new CheckSetUpHashMapGenerator(setUpRan))
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 11.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
@SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait. static void awaitWaiting(Thread t) { while (true) { Thread.State state = t.getState(); switch (state) { case RUNNABLE: case BLOCKED: Thread.yield(); break; case WAITING: return; default: throw new AssertionError("unexpected state: " + state); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 13.8K bytes - Click Count (0) -
compat/maven-compat/src/test/java/org/apache/maven/artifact/testutils/TestFileManager.java
this.fileSuffix = fileSuffix; initializeCleanupMonitoring(); } private void initializeCleanupMonitoring() { callerInfo = new NullPointerException().getStackTrace()[2]; Runnable warning = this::maybeWarnAboutCleanUp; cleanupWarning = new Thread(warning); Runtime.getRuntime().addShutdownHook(cleanupWarning); } private void maybeWarnAboutCleanUp() {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Sep 17 10:01:14 GMT 2025 - 4.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
private Thread executionThread; private Throwable thrownByExecutionThread; private final Executor exceptionCatchingExecutor = new Executor() { @Override public void execute(Runnable command) { executionThread = new Thread(command); executionThread.setUncaughtExceptionHandler( (thread, throwable) -> thrownByExecutionThread = throwable); executionThread.start();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 12.8K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MoreExecutorsDirectExecutorBenchmark.java
return directExecutor(); } }; abstract Executor executor(); } @Param Impl impl; Executor executor; static final class CountingRunnable implements Runnable { AtomicInteger integer = new AtomicInteger(); @Override public void run() { integer.incrementAndGet(); } } CountingRunnable countingRunnable = new CountingRunnable();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 3.4K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java
@Override public Thread newThread(Runnable r) { Thread newThread = new Thread(GROUP, r, "resolver-" + THREAD_NUMBER.getAndIncrement()); newThread.setDaemon(true); newThread.setContextClassLoader(null); return newThread; } } private class ResolveTask implements Runnable { private final ClassLoader classLoader;Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 25K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/TestLocking.java
import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Test class for SMB file locking operations. * This class is used to test concurrent file access and locking behavior. */ public class TestLocking implements Runnable { private static final Logger logger = LoggerFactory.getLogger(TestLocking.class); /** * Default constructor for TestLocking */ public TestLocking() { // Default constructorCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 4.2K bytes - Click Count (0)