- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Updated (0.18 sec)
-
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
static final int CONTAINS_VALUE_RETRIES = 3; /** * Number of cache access operations that can be buffered per segment before the cache's recency * ordering information is updated. This is used to avoid lock contention by recording a memento * of reads and delaying a lock acquisition until the threshold is crossed or a mutation occurs. * * <p>This must be a (2^n)-1 as it is used as a mask.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 91.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
} @Override public ActionFuture<UpdateResponse> update(final UpdateRequest request) { return client.update(request); } @Override public void update(final UpdateRequest request, final ActionListener<UpdateResponse> listener) { client.update(request, listener); } @Override public UpdateRequestBuilder prepareUpdate() {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 84.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Multimaps.java
* {@code factory}, and the multimap contents are all serializable. * * <p>The multimap is not threadsafe when any concurrent operations update the multimap, even if * {@code map} and the instances generated by {@code factory} are. Concurrent read operations will * work correctly. To allow concurrent update operations, wrap the multimap with a call to {@link * #synchronizedMultimap}. *
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 86.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java
// let computation complete letGetFinishSignal.countDown(); getFinishedSignal.await(); checkNothingLogged(); // asMap view should have been updated assertEquals(2, cache.size()); assertEquals(getKey + suffix, map.get(getKey)); assertEquals(refreshKey + suffix, map.get(refreshKey)); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 86.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheLoadingTest.java
// let computation complete letGetFinishSignal.countDown(); getFinishedSignal.await(); checkNothingLogged(); // asMap view should have been updated assertEquals(2, cache.size()); assertEquals(getKey + suffix, map.get(getKey)); assertEquals(refreshKey + suffix, map.get(refreshKey)); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 86.2K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Preconditions.java
* one as it is because one of our users has defined a wrapper API around Preconditions, * declaring a checkState method that accepts a possibly null template. So we'd need to update * that user first. */ @CheckForNull String errorMessageTemplate, @CheckForNull @Nullable Object... errorMessageArgs) { if (!expression) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 11 11:52:14 GMT 2024 - 52.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
AbstractFuture<?> future, @CheckForNull Waiter expect, @CheckForNull Waiter update) { return waitersUpdater.compareAndSet(future, expect, update); } @Override boolean casListeners(AbstractFuture<?> future, @CheckForNull Listener expect, Listener update) { return listenersUpdater.compareAndSet(future, expect, update); } /** Performs a GAS operation on the {@link #listeners} field. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/json/SearchApiManager.java
} final String id = DocumentUtil.getValue(doc, fessConfig.getIndexFieldId(), String.class); searchHelper.update(id, builder -> { final Script script = ComponentUtil.getLanguageHelper().createScript(doc, "ctx._source." + fessConfig.getIndexFieldFavoriteCount() + "+=1");
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 02:17:23 GMT 2024 - 50.3K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheBuilder.java
return (initialCapacity == UNSET_INT) ? DEFAULT_INITIAL_CAPACITY : initialCapacity; } /** * Guides the allowed concurrency among update operations. Used as a hint for internal sizing. The * table is internally partitioned to try to permit the indicated number of concurrent updates * without contention. Because assignment of entries to these partitions is not necessarily
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 51.3K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
break; default: throw new SmbUnsupportedOperationException(); } if ( oldHash != null ) { dgst.update(oldHash); } dgst.update(input, off, len); return dgst.digest(); } Cipher createEncryptionCipher ( byte[] key ) throws CIFSException { if ( !this.smb2 || this.negotiated == null ) {
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Wed Jan 18 23:47:00 GMT 2023 - 67K bytes - Viewed (0)