- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for runOnThread (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
* Used when the same object is being processed on multiple threads. * * @param keyObj the crawler object running on an additional thread */ public void runOnThread(final Object keyObj) { getCacheKey(keyObj).ifPresent(key -> { try { final StatsObject data = statsCache.getIfPresent(key); if (data != null) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 17.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/CrawlerStatsHelperTest.java
@Test public void test_beginDoneWithRecordOnLazy() { String key = "test"; crawlerStatsHelper.begin(key); crawlerStatsHelper.record(key, "aaa"); crawlerStatsHelper.runOnThread(key); crawlerStatsHelper.done(key); logger.info(localLogMsg.get()); assertNull(localLogMsg.get()); crawlerStatsHelper.done(key); logger.info(localLogMsg.get());Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 15.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java
final StatsKeyObject keyObj = paramMap.get(Constants.CRAWLER_STATS_KEY) instanceof final StatsKeyObject sko ? sko : null; if (keyObj != null) { crawlerStatsHelper.runOnThread(keyObj); } final DataStoreParams localParams = paramMap.newInstance(); executor.execute(() -> { try {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 29.7K bytes - Click Count (3)