- Sort Score
- Result 10 results
- Languages All
Results 351 - 360 of 744 for Executed (0.08 sec)
-
guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
// If the delegate is already done, run the execution list immediately on the current // thread. executionList.execute(); return; } // TODO(lukes): handle RejectedExecutionException adapterExecutor.execute( () -> { try { /* * Threads from our private pool are never interrupted. Threads from a
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 7.5K bytes - Viewed (0) -
cmd/post-policy_test.go
req.Header.Set("Content-Type", contentTypeHdr) req.Header.Set("User-Agent", "Mozilla") // Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler. // Call the ServeHTTP to execute the handler. apiRouter.ServeHTTP(rec, req) ctx, cancel := context.WithCancel(GlobalContext) defer cancel()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 30.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CorrettoTest.kt
client.newCall(request).execute().use { assertThat(it.protocol).isEqualTo(Protocol.HTTP_2) assertThat(it.handshake!!.tlsVersion).isEqualTo(TlsVersion.TLS_1_3) } } @Test @Disabled fun testGoogle() { assumeNetwork() val request = Request.Builder().url("https://google.com/robots.txt").build() client.newCall(request).execute().use {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ActivityHelper.java
public void access(final OptionalThing<FessUserBean> user, final String path, final String execute) { final Map<String, String> valueMap = new LinkedHashMap<>(); valueMap.put("action", Action.ACCESS.name()); valueMap.put("user", user.map(FessUserBean::getUserId).orElse("-")); valueMap.put("path", path); valueMap.put("execute", execute); log(valueMap); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 7.7K bytes - Viewed (0) -
regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt
@After fun tearDown() { engine.shutdown() cacheDir.deleteRecursively() } @Test fun get() { val executor = Executors.newCachedThreadPool() val completableFuture = execute(engine, executor, "https://google.com/robots.txt") try { val response = completableFuture.get(10, TimeUnit.SECONDS) assertEquals(200, response.code)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Mar 24 13:19:43 UTC 2024 - 6.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/documents/ApiAdminDocumentsAction.java
@Resource protected SearchEngineClient searchEngineClient; // =================================================================================== // Search Execute // // POST /api/admin/documents/bulk @Execute public JsonResponse<ApiResult> post$bulk(final BulkBody body) { validateApi(body, messages -> {}); if (body.documents == null) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Jul 25 01:48:41 UTC 2024 - 7.5K bytes - Viewed (0) -
src/main/java/org/codelibs/core/sql/StatementUtil.java
* SQL文字列。{@literal null}や空文字列であってはいけません * @return 実行した結果 * @see Statement#execute(String) */ public static boolean execute(final Statement statement, final String sql) { assertArgumentNotNull("statement", statement); assertArgumentNotEmpty("sql", sql); try { return statement.execute(sql); } catch (final SQLException ex) { throw new SQLRuntimeException(ex);
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 5.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
} fail("Expected connection to be closed") } }, ), ) cancelLater(call, 500) assertFailsWith<IOException> { call.execute() }.also { expected -> assertEquals(cancelMode == INTERRUPT, Thread.interrupted()) } } @ParameterizedTest @ArgumentsSource(CancelModelParamProvider::class)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ListeningExecutorService service = listeningDecorator(delegate); Runnable task = new Runnable() { @Override public void run() {} }; service.execute(task); verify(delegate).execute(task); } public void testListeningDecorator_scheduleSuccess() throws Exception { final CountDownLatch completed = new CountDownLatch(1); ScheduledThreadPoolExecutor delegate =
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 28.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/BooleanQueryCommand.java
@Override protected String getQueryClassName() { return BooleanQuery.class.getSimpleName(); } @Override public QueryBuilder execute(final QueryContext context, final Query query, final float boost) { if (query instanceof final BooleanQuery booleanQuery) { if (logger.isDebugEnabled()) { logger.debug("{}:{}", query, boost);
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 2.9K bytes - Viewed (0)