- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 658 for task (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)