Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 237 for Runnables (0.05 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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 constructor
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 4.2K bytes
    - Click Count (0)
Back to Top