- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 789 for executes (0.15 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
public String get(long time, TimeUnit unit) { return "foo"; // BAD!! } @Override public void addListener(Runnable runnable, Executor executor) { executor.execute(runnable); } }; Future<?> future = newFutureInstance(); future .getClass() .getMethod( "setFuture",
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 6.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
public String get(long time, TimeUnit unit) { return "foo"; // BAD!! } @Override public void addListener(Runnable runnable, Executor executor) { executor.execute(runnable); } }; Future<?> future = newFutureInstance(); future .getClass() .getMethod( "setFuture",
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 6.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/LoomTest.kt
.build() } private fun newVirtualThreadPerTaskExecutor(): ExecutorService = Executors::class.java.getMethod("newVirtualThreadPerTaskExecutor").invoke(null) as ExecutorService @Test fun testRequest() { server.enqueue(MockResponse()) val request = Request(server.url("/")) client.newCall(request).execute().use { assertThat(it.code).isEqualTo(200) } } @Test
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 2K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/job/PythonJobTest.java
} // Test execute method with successful execution public void test_execute_success() { pythonJob.filename("test.py"); pythonJob.args("arg1", "arg2"); testProcessHelper.exitValue = 0; testProcessHelper.processOutput = "Python script executed successfully"; String result = pythonJob.execute(); assertNotNull(result);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 22.1K bytes - Viewed (0) -
docs/en/docs/advanced/settings.md
``` your program could execute like this: ```mermaid sequenceDiagram participant code as Code participant function as say_hi() participant execute as Execute function rect rgba(0, 255, 0, .1) code ->> function: say_hi(name="Camila") function ->> execute: execute function code execute ->> code: return the result end
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 12.2K bytes - Viewed (0) -
docs/pt/docs/virtual-environments.md
Um `requirements.txt` com alguns pacotes poderia se parecer com: ```requirements.txt fastapi[standard]==0.113.0 pydantic==2.8.0 ``` /// ## Execute seu programa Depois de ativar o ambiente virtual, você pode executar seu programa, e ele usará o Python dentro do seu ambiente virtual com os pacotes que você instalou lá. <div class="termy"> ```console $ python main.py Hello World
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sat Nov 09 16:39:20 UTC 2024 - 22.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java
/** * An abstract {@code ScheduledExecutorService} that allows subclasses to {@linkplain * #wrapTask(Callable) wrap} tasks before they are submitted to the underlying executor. * * <p>Note that task wrapping may occur even if the task is never executed. * * @author Luke Sandberg */ @J2ktIncompatible @GwtIncompatible abstract class WrappingScheduledExecutorService extends WrappingExecutorService
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.4K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/DcerpcConstants.java
int DCERPC_RESERVED_1 = 0x08; /** * Supports concurrent multiplexing flag. */ int DCERPC_CONC_MPX = 0x10; /* supports concurrent multiplexing */ /** * Did not execute flag - indicates request was not executed */ int DCERPC_DID_NOT_EXECUTE = 0x20; /** * Maybe flag - indicates 'maybe' call semantics requested */ int DCERPC_MAYBE = 0x40; /* `maybe' call semantics requested */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
setUp(protocol) server.enqueue(MockResponse(body = "A")) server.enqueue(MockResponse(body = "A")) val executor = Executors.newCachedThreadPool(threadFactory("HttpOverHttp2Test")) val countDownLatch = CountDownLatch(2) executor.execute(AsyncRequest("/r1", countDownLatch)) executor.execute(AsyncRequest("/r2", countDownLatch)) countDownLatch.await() assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 73.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java
@Override public String call() { return "foo"; } } /** Simple same thread listening executor service that doesn't handle shutdown. */ private static class TestListeningExecutorService extends AbstractListeningExecutorService { @Override public void execute(Runnable runnable) { assertThat(runnable).isInstanceOf(TrustedListenableFutureTask.class); runnable.run(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 3.2K bytes - Viewed (0)