Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 190 for ctMask (0.04 seconds)

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

                    hasSetRunning = true;
                  }
                }
                task = queue.poll();
                if (task == null) {
                  workerRunningState = IDLE;
                  return;
                }
              }
              // Remove the interrupt bit before each task. The interrupt is for the "current task" when
              // it is sent, so subsequent tasks in the queue should not be caused to be interrupted
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
  2. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

                    hasSetRunning = true;
                  }
                }
                task = queue.poll();
                if (task == null) {
                  workerRunningState = IDLE;
                  return;
                }
              }
              // Remove the interrupt bit before each task. The interrupt is for the "current task" when
              // it is sent, so subsequent tasks in the queue should not be caused to be interrupted
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
  3. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.private-javadoc.gradle.kts

            }
        }
    }
    
    tasks.withType<Javadoc>().configureEach {
        assert(name != "javadocAll") // This plugin should not be applied to the :docs project.
    
        onlyIf("Do not run the task if there are no java sources") {
            // Javadoc task will complain if we only have package-info.java files and no
            // other java files (as is with some Kotlin projects)
            !source.matching {
                exclude("**/package-info.java")
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Aug 20 14:11:17 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  4. build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleKotlinDslReferencePlugin.java

                .register("gradleKotlinDslRuntimeGeneratedSources", GradleKotlinDslRuntimeGeneratedSources.class, task -> {
                    task.getGeneratedSources().set(project.getLayout().getBuildDirectory().dir("gradle-kotlin-dsl-extensions/sources"));
                    task.getGeneratedClasses().set(project.getLayout().getBuildDirectory().dir("gradle-kotlin-dsl-extensions/classes"));
                });
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed May 28 11:34:42 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  5. tests/test_tutorial/test_response_change_status_code/test_tutorial001.py

    client = TestClient(app)
    
    
    def test_path_operation():
        response = client.put("/get-or-create-task/foo")
        print(response.content)
        assert response.status_code == 200, response.text
        assert response.json() == "Listen to the Bar Fighters"
        response = client.put("/get-or-create-task/bar")
        assert response.status_code == 201, response.text
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 526 bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                directExecutor());
    
        // Wait for the first task to be started in the background. It will block until we explicitly
        // stop it.
        blockingCallable.waitForStart();
    
        // Give the second task a chance to (incorrectly) start up while the first task is running.
        assertThat(future2.isDone()).isFalse();
    
        // Stop the first task. The second task should then run.
        blockingCallable.stop();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        public <T> Future<T> submit(Callable<T> task) {
          lastMethodCalled = "submit";
          assertThat(task).isInstanceOf(WrappedCallable.class);
          return inline.submit(task);
        }
    
        @Override
        public Future<?> submit(Runnable task) {
          lastMethodCalled = "submit";
          assertThat(task).isInstanceOf(WrappedRunnable.class);
          return inline.submit(task);
        }
    
        @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Jul 14 14:44:08 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  8. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * will not be released until that submitted task is also complete.
       *
       * <p>If a task is {@linkplain Thread#interrupt interrupted} while a task is running:
       *
       * <ol>
       *   <li>execution will not stop until the task queue is empty.
       *   <li>tasks will begin execution with the thread marked as not interrupted - any interruption
       *       applies only to the task that was running at the point of interruption.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 45.2K bytes
    - Click Count (0)
  9. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/testcleanup/TestFilesCleanupRootPlugin.kt

            }
        }
    
        private
        fun Task.findTraceJson(): List<File> {
            if (this !is Test) {
                return emptyList()
            }
            // e.g. build/test-results/embeddedIntegTest/trace.json
            return listOf(project.layout.buildDirectory.file("test-results/$name/trace.json").get().asFile)
        }
    
        private
        fun Task.genericHtmlReports() = when (this) {
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu Jul 06 10:57:13 GMT 2023
    - 3K bytes
    - Click Count (0)
  10. cmd/admin-heal-ops.go

    			if serverDebugLog {
    				fmt.Printf("Task in the queue: %#v\n", task)
    			}
    		default:
    			// task queue is full, no more workers, we shall move on and heal later.
    			return nil
    		}
    		// Don't wait for result
    		return nil
    	}
    
    	// respCh must be set to wait for result.
    	// We make it size 1, so a result can always be written
    	// even if we aren't listening.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
Back to Top