- Sort Score
- Result 10 results
- Languages All
Results 541 - 550 of 744 for Executed (0.07 sec)
-
android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java
* - Terminated: runningTasks == 0 and shutdown == true */ @GuardedBy("lock") private int runningTasks = 0; @GuardedBy("lock") private boolean shutdown = false; @Override public void execute(Runnable command) { startTask(); try { command.run(); } finally { endTask(); } } @Override public boolean isShutdown() { synchronized (lock) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 3.5K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/internal/-MainCommon.kt
return s.equals("Content-Type", ignoreCase = true) } fun Main.commonRun() { client = createClient() val request = createRequest() try { val response = client!!.newCall(request).execute() if (showHeaders) { println(StatusLine.get(response)) val headers = response.headers for ((name, value) in headers) { println("$name: $value") } println() }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
* may ultimately cause the application to slow down or crash. * * Both this class and [Response] implement [Closeable]. Closing a response simply * closes its response body. If you invoke [Call.execute] or implement [Callback.onResponse] you * must close this body by calling any of the following methods: * * * `Response.close()` * * `Response.body().close()` * * `Response.body().source().close()`
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java
if (fessConfig.isSmbRoleFromFile() || fessConfig.isFileRoleFromFile() || fessConfig.isFtpRoleFromFile()) { // head method responseData = client.execute(RequestDataBuilder.newRequestData().head().url(url).build()); if (responseData == null) { return true; }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 14.6K bytes - Viewed (0) -
api/maven-api-cli/src/main/java/org/apache/maven/api/cli/mvn/MavenOptions.java
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Thu Oct 03 16:03:55 UTC 2024 - 8.3K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerWriter.kt
for (shift in (lengthByteCount - 1) * 8 downTo 0 step 8) { sink.writeByte((length shr shift).toInt()) } } // Write the payload. sink.writeAll(content) } /** * Execute [block] with a new namespace for type hints. Type hints from the enclosing type are no * longer usable by the current type's members. */ fun <T> withTypeHint(block: () -> T): T { typeHintStack.add(null)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
Service service = new TestService() { @Override protected Executor executor() { return new Executor() { @Override public void execute(Runnable command) {} }; } @Override protected String serviceName() { return "Foo"; } }; TimeoutException e =
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 7.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
awaitUnchecked(barrier); task.run(); awaitUnchecked(barrier); } }; for (int j = 0; j < 10; j++) { executor.execute(wrapper); } barrier.await(); // release the threads! barrier.await(); // wait for them all to complete assertEquals(1, task.get().intValue()); assertEquals(1, counter.get()); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 15:41:36 UTC 2024 - 7.3K bytes - Viewed (0) -
docs/multi-tenancy/README.md
export MINIO_ROOT_USER=<TENANT3_ACCESS_KEY> export MINIO_ROOT_PASSWORD=<TENANT3_SECRET_KEY> minio server --address :9003 http://192.168.10.1{1...4}/data/tenant3 ``` **Note:** Execute the commands on all 4 nodes. ![Example-3](https://github.com/minio/minio/blob/master/docs/screenshots/Example-3.jpg?raw=true)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 3K bytes - Viewed (0) -
src/test/java/org/codelibs/curl/io/IOIntegrationTest.java
req.threshold(0); // always create tmp file // ## Act ## long before = countTmpFiles(); logger.info("Before request. Number of temp files: " + before); req.execute(res -> { logger.info("Processing request. Number of temp files: " + countTmpFiles()); }, e -> {}); long after = countTmpFiles();
Registered: Thu Oct 31 02:32:13 UTC 2024 - Last Modified: Mon Nov 14 21:05:19 UTC 2022 - 3.4K bytes - Viewed (0)