- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for executors (0.17 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
fail(); } throw new MyError(); } }; } // TODO(cpovirk): top-level class? static class ExecutorSpy implements Executor { Executor delegate; boolean wasExecuted; public ExecutorSpy(Executor delegate) { this.delegate = delegate; } @Override public void execute(Runnable command) { delegate.execute(command);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
fail(); } throw new MyError(); } }; } // TODO(cpovirk): top-level class? static class ExecutorSpy implements Executor { Executor delegate; boolean wasExecuted; public ExecutorSpy(Executor delegate) { this.delegate = delegate; } @Override public void execute(Runnable command) { delegate.execute(command);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
.body("def") .throttleBody(1, 750, TimeUnit.MILLISECONDS) .build(), ) val call = client.newCall(Request(server.url("/a"))) val executor = Executors.newSingleThreadExecutor() val result = executor.submit<Response?> { call.execute() } Thread.sleep(100) // wait for it to go in flight. call.cancel() assertFailsWith<IOException> { result.get()!!.body.bytes()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* exception itself. * @param executor the executor that runs {@code fallback} if the input fails */ public <X extends Throwable> ClosingFuture<V> catching( Class<X> exceptionType, ClosingFunction<? super X, ? extends V> fallback, Executor executor) { return catchingMoreGeneric(exceptionType, fallback, executor); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ClosingFuture.java
* exception itself. * @param executor the executor that runs {@code fallback} if the input fails */ public <X extends Throwable> ClosingFuture<V> catching( Class<X> exceptionType, ClosingFunction<? super X, ? extends V> fallback, Executor executor) { return catchingMoreGeneric(exceptionType, fallback, executor); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 98.7K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ArtifactTransformCachingIntegrationTest.groovy
setupProjectInDir(projectDir1) setupProjectInDir(projectDir2) executer.requireIsolatedDaemons() executer.beforeExecute { if (!GradleContextualExecuter.embedded) { executer.withArgument("-D$REUSE_USER_HOME_SERVICES=true") } } when: executer.inDirectory(projectDir1) succeeds ":util:resolve", ":app:resolve" then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 11:52:44 UTC 2024 - 97.8K bytes - Viewed (0) -
src/database/sql/sql.go
if err == nil || !errors.Is(err, driver.ErrBadConn) { return err } } return fn(alwaysNewConn) } // PrepareContext creates a prepared statement for later queries or executions. // Multiple queries or executions may be run concurrently from the // returned statement. // The caller must call the statement's [*Stmt.Close] method // when the statement is no longer needed. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tf_passes.td
} def BreakUpIslandsPass : Pass<"tf-executor-break-up-islands", "mlir::func::FuncOp"> { let summary = "Transform from TF control dialect to TF executor dialect."; let constructor = "CreateBreakUpIslandsPass()"; let dependentDialects = ["mlir::tf_executor::TensorFlowExecutorDialect"]; } def SplitIntoIslandPerOpPass : Pass<"tf-executor-split-into-island-per-op", "mlir::func::FuncOp"> {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jun 12 21:18:05 UTC 2024 - 99.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ArtifactTransformIntegrationTest.groovy
failure.assertHasCause("broken") and: outputContains("Transforming b.jar") when: executer.withArgument("-Plenient=true") succeeds("resolve") then: outputContains("files: [b.jar]") }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Nov 07 18:43:42 UTC 2023 - 100.8K bytes - Viewed (0) -
api/maven-api-model/src/main/mdo/maven.mdo
<type>int</type> <description> The priority of this execution compared to other executions which are bound to the same phase. Executions derived from the default lifecycle have a negative priority by default so that they are executed before any custom plugin executions. @since Maven 4.0.0 </description> </field> <field>
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Apr 23 13:29:46 UTC 2024 - 115.1K bytes - Viewed (0)