Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 176 for Runnable (0.21 sec)

  1. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

                      + runnable
                      + " with executor "
                      + executor,
                  e);
        }
      }
    
      private static final class RunnableExecutorPair {
        final Runnable runnable;
        final Executor executor;
        @CheckForNull RunnableExecutorPair next;
    
        RunnableExecutorPair(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      static Thread newThread(String name, Runnable runnable) {
        checkNotNull(name);
        checkNotNull(runnable);
        // TODO(b/139726489): Confirm that null is impossible here.
        Thread result = requireNonNull(platformThreadFactory().newThread(runnable));
        try {
          result.setName(name);
        } catch (SecurityException e) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

      private val busyQueues = mutableListOf<TaskQueue>()
    
      /** Queues not in [busyQueues] that have non-empty [TaskQueue.futureTasks]. */
      private val readyQueues = mutableListOf<TaskQueue>()
    
      private val runnable: Runnable =
        object : Runnable {
          override fun run() {
            var incrementedRunCallCount = false
            while (true) {
              val task =
                ******@****.***ck {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  4. build-logic/buildquality/src/main/kotlin/gradlebuild.arch-test.gradle.kts

                }
            }
        }
    }
    
    tasks.codeQuality.configure {
        dependsOn(testing.suites.named("archTest"))
    }
    
    fun notForAccessorGeneration(runnable: Runnable) {
        if (project.name != "gradle-kotlin-dsl-accessors" && project.name != "test") {
            runnable.run()
        }
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Wed Apr 03 13:29:44 GMT 2024
    - 3K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

        TaskRunner(
          object : TaskRunner.Backend {
            override fun execute(
              taskRunner: TaskRunner,
              runnable: Runnable,
            ) {
              taskRunner.assertThreadHoldsLock()
    
              val queuedTask = RunnableSerialTask(runnable)
              serialTaskQueue += queuedTask
              executeCallCount++
              isParallel = serialTaskQueue.size > 1
            }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  6. okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt

      }
    
      @JvmStatic
      fun threadFactory(name: String): ThreadFactory {
        return object : ThreadFactory {
          private var nextId = 1
    
          override fun newThread(runnable: Runnable): Thread {
            return Thread(runnable, "$name-${nextId++}")
          }
        }
      }
    }
    
    fun getEnv(name: String) = System.getenv(name)
    
    val SYSTEM_FILE_SYSTEM = FileSystem.SYSTEM
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 4.3K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

        }
      }
    
      /**
       * Submits the given runnable to the given {@link Executor} catching and logging all {@linkplain
       * RuntimeException runtime exceptions} thrown by the executor.
       */
      @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
      private static void executeListener(Runnable runnable, Executor executor) {
        try {
          executor.execute(runnable);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 63K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/core/timer/TimeoutManager.java

    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.log.Logger;
    
    /**
     * Timerを扱うクラスです。
     *
     * @author higa
     *
     */
    public class TimeoutManager implements Runnable {
    
        private static final Logger logger = Logger.getLogger(TimeoutManager.class);
    
        /**
         * シングルトンのためのインスタンスです。
         */
        protected static final TimeoutManager instance = new TimeoutManager();
    
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 8K bytes
    - Viewed (0)
  9. maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

            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;
    
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Thu Apr 25 05:46:50 GMT 2024
    - 24.8K bytes
    - Viewed (0)
  10. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

            super(0);
          }
        }
    
        public static final class DummyRunnable implements Runnable, Serializable {
          @Override
          public void run() {}
        }
    
        public static final class DummyThreadFactory implements ThreadFactory, Serializable {
          @Override
          public Thread newThread(Runnable r) {
            return new Thread(r);
          }
        }
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 21K bytes
    - Viewed (1)
Back to top