- Sort Score
- Result 10 results
- Languages All
Results 371 - 380 of 688 for Thread (0.03 sec)
-
src/main/resources/fess_label_it.properties
labels.includedDocPaths=Percorsi da includere nella ricerca labels.includedDocUrls=URL da includere nella ricerca labels.maxAccessCount=Numero massimo di accessi labels.name=Nome labels.numOfThread=Numero di thread labels.duplicateHostName=Nome duplicato labels.pageNumber=Numero di pagina labels.password=Password labels.paths=Percorsi labels.port=Porta labels.regex=Espressione regolare labels.regularName=Nome regolare
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 10 04:56:21 UTC 2025 - 43.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/SubscriberTest.java
} public void testCreate() { Subscriber s1 = Subscriber.create(bus, this, getTestSubscriberMethod("recordingMethod")); assertThat(s1).isInstanceOf(Subscriber.SynchronizedSubscriber.class); // a thread-safe method should not create a synchronized subscriber Subscriber s2 = Subscriber.create(bus, this, getTestSubscriberMethod("threadSafeMethod")); assertThat(s2).isNotInstanceOf(Subscriber.SynchronizedSubscriber.class); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Feb 13 17:34:21 UTC 2025 - 4.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
.forEach(s -> buf.append(s)); log(buf); } /** * Increments the thread reference count for the specified crawler object. * 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 -> {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 17.4K bytes - Viewed (0) -
src/main/resources/fess_label_en.properties
labels.query=Query labels.queryId=Query ID labels.rt=rt labels.searchLog=Search Log labels.sort=Sort labels.start=Start labels.loginRequired=Login Required labels.loginLink=Show Login Link labels.threadName=Thread Name labels.url=URL labels.userFavorite=Favorite Log labels.userInfo=User Info labels.webApiJson=JSON Response labels.webConfigName=Web Crawl Config Name labels.allLanguages=All Languages labels.dictId=Dictionary ID
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 10 04:56:21 UTC 2025 - 40.7K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/DnsOverHttpsTest.kt
assertThat(recordedRequest.url.encodedQuery).isEqualTo( "ct&dns=AAABAAABAAAAAAAABmdvb2dsZQNjb20AAAEAAQ", ) assertThat(cacheEvents()).containsExactly("CacheMiss") Thread.sleep(2000) server.enqueue( dnsResponse( "0000818000010003000000000567726170680866616365626f6f6b03636f6d0000010001c00c000500010" +
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 11.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProtocolHelper.java
*/ protected void loadProtocols(final String basePackage) { final List<String> subPackages = new ArrayList<>(); final String path = basePackage.replace('.', '/'); final ClassLoader classLoader = Thread.currentThread().getContextClassLoader(); try { final Enumeration<URL> resources = classLoader.getResources(path); while (resources.hasMoreElements()) {Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 9.7K bytes - Viewed (1) -
android/guava/src/com/google/common/collect/Queues.java
} buffer.add(e); added++; } } } finally { if (interrupted) { Thread.currentThread().interrupt(); } } return added; } /** * Returns a synchronized (thread-safe) queue backed by the specified queue. In order to guarantee * serial access, it is critical that <b>all</b> access to the backing queue is accomplishedRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 18.3K bytes - Viewed (0) -
src/main/java/jcifs/util/SecureKeyManager.java
private final java.util.concurrent.ScheduledExecutorService rotationScheduler = java.util.concurrent.Executors.newSingleThreadScheduledExecutor(r -> { Thread t = new Thread(r, "SecureKeyManager-Rotation"); t.setDaemon(true); return t; }); private java.util.concurrent.ScheduledFuture<?> rotationTask; /**Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 21.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java
import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /** * Basher test for {@link ConcurrentHashMultiset}: start a bunch of threads, have each of them do * operations at random. Each thread keeps track of the per-key deltas that it's directly * responsible for; after all threads have completed, we sum the per-key deltas and compare to the * existing multiset values. * * @author mike nonemacher */ @NullUnmarkedRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 6K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java
return new Metadata(new MetadataStaxReader().read(in, false)); } catch (FileNotFoundException e) { throw new RepositoryMetadataReadException("Cannot read metadata from '" + mappingFile + "'", e); } catch (IOException | XMLStreamException e) { throw new RepositoryMetadataReadException( "Cannot read metadata from '" + mappingFile + "': " + e.getMessage(), e); }
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 18.9K bytes - Viewed (0)