Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 322 for tasks (0.02 sec)

  1. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        final Queue<Runnable> tasks = new ArrayDeque<>();
    
        @Override
        public void execute(Runnable command) {
          tasks.add(command);
        }
    
        boolean hasNext() {
          return !tasks.isEmpty();
        }
    
        void runNext() {
          assertTrue("expected at least one task to run", hasNext());
          tasks.remove().run();
        }
    
        void runAll() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  2. cmd/background-heal-ops.go

    	for {
    		select {
    		case task, ok := <-h.tasks:
    			if !ok {
    				return
    			}
    
    			var res madmin.HealResultItem
    			var err error
    			switch task.bucket {
    			case nopHeal:
    				err = errSkipFile
    			case SlashSeparator:
    				res, err = healDiskFormat(ctx, objAPI, task.opts)
    			default:
    				if task.object == "" {
    					res, err = objAPI.HealBucket(ctx, task.bucket, task.opts)
    				} else {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  3. .teamcity/src/main/kotlin/configurations/TestPerformanceTest.kt

            val buildTypeThis = this
            val testProject = "smallJavaMultiProject"
    
            fun BuildSteps.gradleStep(tasks: List<String>) {
                gradleWrapper {
                    name = "GRADLE_RUNNER"
                    gradleParams =
                        (
                            tasks +
                                buildToolGradleParameters(isContinue = false)
                        ).joinToString(separator = " ")
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Mon Aug 25 20:21:47 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  4. okcurl/build.gradle.kts

    }
    
    configure<AnimalSnifferExtension> {
      isIgnoreFailures = true
    }
    
    tasks.jar {
      manifest {
        attributes("Automatic-Module-Name" to "okhttp3.curl")
        attributes("Main-Class" to "okhttp3.curl.MainCommandLineKt")
      }
    }
    
    tasks.shadowJar {
      mergeServiceFiles()
    }
    
    tasks.withType<Test> {
      onlyIf("native build requires Java 17") {
        testJavaVersion > 17
      }
    }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 22 20:31:49 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

            try {
              while (true) {
                currentThread.name = task.name
                val delayNanos =
                  logger.logElapsed(task, task.queue!!) {
                    task.runOnce()
                  }
    
                // A task ran successfully. Update the execution state and take the next task.
                task = withLock {
                  afterRun(task, delayNanos, true)
                  awaitTaskToRun()
                } ?: return
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  6. cmd/metrics-v3-ilm.go

    )
    
    var (
    	ilmExpiryPendingTasksMD             = NewGaugeMD(expiryPendingTasks, "Number of pending ILM expiry tasks in the queue")
    	ilmTransitionActiveTasksMD          = NewGaugeMD(transitionActiveTasks, "Number of active ILM transition tasks")
    	ilmTransitionPendingTasksMD         = NewGaugeMD(transitionPendingTasks, "Number of pending ILM transition tasks in the queue")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Jun 06 09:36:25 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  7. okhttp/build.gradle.kts

    }
    
    afterEvaluate {
      tasks.withType<Test> {
        if (javaLauncher.get().metadata.languageVersion.asInt() < 9) {
          // Work around robolectric requirements and limitations
          // https://cs.android.com/android-studio/platform/tools/base/+/mirror-goog-studio-main:build-system/gradle-core/src/main/java/com/android/build/gradle/tasks/factory/AndroidUnitTest.java;l=339
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 03 03:59:03 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

        }
    
        @Override
        public <T> Future<T> submit(Callable<T> task) {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public Future<?> submit(Runnable task) {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public <T> Future<T> submit(Runnable task, T result) {
          throw new UnsupportedOperationException();
        }
    
        @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/cache/CacheLoaderTest.java

    public class CacheLoaderTest extends TestCase {
    
      private static class QueuingExecutor implements Executor {
        private final Deque<Runnable> tasks = new ArrayDeque<>();
    
        @Override
        public void execute(Runnable task) {
          tasks.add(task);
        }
    
        private void runNext() {
          tasks.removeFirst().run();
        }
      }
    
      public void testAsyncReload() throws Exception {
        AtomicInteger loadCount = new AtomicInteger();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  10. .teamcity/src/main/kotlin/promotion/SanityCheck.kt

        description = "Sanity check for promotion project"
    
        vcs.useAbsoluteVcs(VersionedSettingsBranch.fromDslContext().gradlePromoteVcsRootId())
    
        steps {
            gradleWrapper {
                tasks = "tasks"
                gradleParams = ""
                param("org.jfrog.artifactory.selectedDeployableServer.defaultModuleVersionConfiguration", "GLOBAL")
            }
        }
    
        triggers {
            vcs {
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Thu Mar 20 06:13:56 UTC 2025
    - 983 bytes
    - Viewed (0)
Back to top