Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 658 for task (0.03 sec)

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

        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
        // Start the task to put it in the RUNNING state.  Have to use a separate
        // thread because the task will block on the task latch after unblocking
        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

        TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2));
        assertFalse(task.isDone());
        task.run();
        assertTrue(task.isDone());
        assertFalse(task.isCancelled());
        assertEquals(2, getDone(task).intValue());
      }
    
      public void testCancelled() throws Exception {
        TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  3. build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/UpgradedPropertiesChangesTest.kt

                    "Method com.example.Task.getIsFailOnError(): Is not annotated with @Incubating. Reason for accepting this: Upgraded property" to listOf("Method added to public class"),
                    "Method com.example.Task.getIsFailOnError(): Is not annotated with @since 2.0. Reason for accepting this: Upgraded property" to listOf("Method added to public class"),
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Oct 02 14:20:08 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  4. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.private-javadoc.gradle.kts

    pluginManager.withPlugin("gradlebuild.code-quality") {
        tasks {
            named("codeQuality") {
                dependsOn(tasks.withType<Javadoc>())
            }
        }
    }
    
    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
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Aug 20 14:11:17 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskLogger.kt

    import java.util.logging.Level
    import java.util.logging.Logger
    
    internal inline fun Logger.taskLog(
      task: Task,
      queue: TaskQueue,
      messageBlock: () -> String,
    ) {
      if (isLoggable(Level.FINE)) {
        log(task, queue, messageBlock())
      }
    }
    
    internal inline fun <T> Logger.logElapsed(
      task: Task,
      queue: TaskQueue,
      block: () -> T,
    ): T {
      var startNs = -1L
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

      public <T extends @Nullable Object> Future<T> submit(Callable<T> task) {
        return delegate().submit(task);
      }
    
      @Override
      public Future<?> submit(Runnable task) {
        return delegate().submit(task);
      }
    
      @Override
      public <T extends @Nullable Object> Future<T> submit(
          Runnable task, @ParametricNullness T result) {
        return delegate().submit(task, result);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

    public final class InterruptibleTaskTest extends TestCase {
    
      // Regression test for a deadlock where a task could be stuck busy waiting for the task to
      // transition to DONE
      public void testInterruptThrows() throws Exception {
        final CountDownLatch isInterruptibleRegistered = new CountDownLatch(1);
        InterruptibleTask<@Nullable Void> task =
            new InterruptibleTask<@Nullable Void>() {
              @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  8. 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();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  9. build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/AlphabeticalAcceptedApiChangesTask.kt

     * limitations under the License.
     */
    
    package gradlebuild.binarycompatibility
    
    import org.gradle.api.GradleException
    import org.gradle.api.tasks.CacheableTask
    import org.gradle.api.tasks.TaskAction
    import java.io.File
    
    
    /**
     * This [Task][org.gradle.api.Task] checks that the contents of a given accepted API changes files
     * are present in alphabetical order (by type, then member), and throws an exception and reports
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Jun 04 14:00:46 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java

      @Override
      public ListenableFuture<?> submit(Runnable task) {
        return (ListenableFuture<?>) super.submit(task);
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      public <T extends @Nullable Object> ListenableFuture<T> submit(
          Runnable task, @ParametricNullness T result) {
        return (ListenableFuture<T>) super.submit(task, result);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 3K bytes
    - Viewed (0)
Back to top