- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 1,889 for Watch (0.01 sec)
-
src/test/java/org/codelibs/fess/util/ThreadDumpUtilTest.java
successCount.incrementAndGet(); } } catch (Exception e) { errorCount.incrementAndGet(); } finally { latch.countDown(); } }).start(); } latch.await(); assertEquals("All threads should succeed", threadCount, successCount.get());
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 07:34:10 UTC 2025 - 15.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/keymatch/ApiAdminKeymatchAction.java
.status(ApiResult.Status.OK) .result()); } /** * Retrieves a specific key match setting by ID. * * @param id the ID of the key match setting to retrieve * @return JSON response containing the key match setting */ // GET /api/admin/keymatch/setting/{id} @Execute public JsonResponse<ApiResult> get$setting(final String id) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 7.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/sql/PreparedStatementUtil.java
try { return ps.execute(); } catch (final SQLException ex) { throw new SQLRuntimeException(ex); } } /** * Executes a batch update. * * @param ps * {@link PreparedStatement}. Must not be {@literal null}. * @return An array of the number of rows affected by each command in the batch. * @throws SQLRuntimeException
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 3.9K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
do { System.runFinalization(); if (latch.getCount() == 0) { return; } System.gc(); try { if (latch.await(1L, SECONDS)) { return; } } catch (InterruptedException ie) { throw new RuntimeException("Unexpected interrupt while waiting for latch", ie); } } while (System.nanoTime() - deadline < 0);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 11.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/ServerMessageBlock2ResponseTest.java
CountDownLatch latch = new CountDownLatch(1); Thread waiter = new Thread(() -> { synchronized (response) { try { if (!response.isReceived()) { response.wait(1000); } latch.countDown(); } catch (InterruptedException e) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 19.3K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/indexer/DocBoostMatcherTest.java
map.put("data1", 20); assertTrue(docBoostMatcher.match(map)); map.put("data1", 5); assertFalse(docBoostMatcher.match(map)); map.remove("data1"); assertFalse(docBoostMatcher.match(map)); map.put("data2", 5); assertFalse(docBoostMatcher.match(map)); } public void test_string() {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 4.6K bytes - Viewed (0) -
cmd/batch-job-common-types_gen_test.go
Krishnan Parthasarathi <******@****.***> 1701514293 -0800
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sat Dec 02 10:51:33 UTC 2023 - 11.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/DispatcherTest.java
dispatcher = Dispatcher.legacyAsync(); CyclicBarrier barrier = new CyclicBarrier(2); CountDownLatch latch = new CountDownLatch(2); new Thread( new Runnable() { @Override public void run() { try { barrier.await(); } catch (Exception e) { throw new AssertionError(e); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 5.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/keymatch/AdminKeymatchAction.java
// ========= /** Helper for key match operations. */ @Resource private KeyMatchHelper keyMatchHelper; /** Service for key match operations. */ @Resource private KeyMatchService keyMatchService; /** Pager for key match list pagination. */ @Resource private KeyMatchPager keyMatchPager;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 16.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
/** Invokes {@code latch.}{@link CountDownLatch#await() await()} uninterruptibly. */ @J2ktIncompatible @GwtIncompatible // concurrency public static void awaitUninterruptibly(CountDownLatch latch) { boolean interrupted = false; try { while (true) { try { latch.await(); return; } catch (InterruptedException e) { interrupted = true;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.8K bytes - Viewed (0)