- Sort Score
- Result 10 results
- Languages All
Results 481 - 490 of 605 for 1000L (0.03 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ListenableFuture<?> future = executor.submit(incrementTask); assertTrue(future.isDone()); assertListenerRunImmediately(future); assertEquals(1, threadLocalCount.get().intValue()); otherThread.join(1000); assertEquals(Thread.State.TERMINATED, otherThread.getState()); Throwable throwable = throwableFromOtherThread.get(); assertNull( "Throwable from other thread: "
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 28.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
List<StringCatcher> catchers = Lists.newCopyOnWriteArrayList(); List<Future<?>> futures = Lists.newArrayList(); ExecutorService executor = Executors.newFixedThreadPool(10); int numberOfCatchers = 10000; for (int i = 0; i < numberOfCatchers; i++) { futures.add(executor.submit(new Registrator(bus, catchers))); } for (int i = 0; i < numberOfCatchers; i++) { futures.get(i).get(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 15:16:45 UTC 2024 - 11.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 11.9K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
@Resource protected OpenSearchDataService dataService; protected Map<String, QueueHolder> sessionCache = new ConcurrentHashMap<>(); protected int pollingFetchSize = 1000; protected int maxCrawlingQueueSize = 100; public OpenSearchUrlQueueService(final OpenSearchCrawlerConfig crawlerConfig) { index = crawlerConfig.getQueueIndex();
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 13.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cookie.kt
if (deltaSeconds == Long.MIN_VALUE) { expiresAt = Long.MIN_VALUE } else if (deltaSeconds != -1L) { val deltaMilliseconds = if (deltaSeconds <= Long.MAX_VALUE / 1000) { deltaSeconds * 1000 } else { Long.MAX_VALUE } expiresAt = currentTimeMillis + deltaMilliseconds if (expiresAt < currentTimeMillis || expiresAt > MAX_DATE) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 06 04:12:05 UTC 2024 - 23.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/taglib/FessFunctions.java
Pattern.compile("[A-Z0-9._%+-]+@[A-Z0-9.-]+\\.[A-Z]{2,6}", Pattern.CASE_INSENSITIVE); private static LoadingCache<String, Long> resourceHashCache = CacheBuilder.newBuilder().maximumSize(1000).expireAfterWrite(10, TimeUnit.MINUTES).build(new CacheLoader<String, Long>() { @Override public Long load(final String key) throws Exception { try {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 16.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/SuppliersTest.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 17.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/SuppliersTest.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 17.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTransport.java
rn = resp.numReferrals; } DfsReferral dr = new DfsReferral(); String[] arr = new String[4]; long expiration = System.currentTimeMillis() + Dfs.TTL * 1000; int di = 0; for ( ;; ) { /* NTLM HTTP Authentication must be re-negotiated * with challenge from 'server' to access DFS vol. */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 31.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ImmutableSortedSetTest.java
for (int i = 0; i < 9; i++) { builder.add(i); } for (int j = 0; j < 1000; j++) { builder.add(9); } ImmutableSortedSet<Integer> unused = builder.build(); assertThat(compares[0]).isAtMost(10000); // hopefully something quadratic would have more digits }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 46.7K bytes - Viewed (0)