- Sort Score
- Num 10 results
- Language All
Results 181 - 190 of 1,079 for concurrent (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/test/java/org/codelibs/fess/auth/chain/AuthenticationChainTest.java
assertEquals(user2, chain.deleteCalls.get(0)); assertEquals("user3", chain.changePasswordCalls.get(0).getKey()); assertEquals(user1, chain.loadCalls.get(0)); } // Test concurrent operations simulation @Test public void test_implementation_sequentialOperations() { TestAuthenticationChain chain = new TestAuthenticationChain(); List<User> users = new ArrayList<>();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 14.8K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/util/SystemUtilTest.java
} else { System.clearProperty(Constants.FESS_SEARCH_ENGINE_HTTP_ADDRESS); } } } @Test public void test_thread_safety() { // Test concurrent access to the method String originalValue = System.getProperty(Constants.FESS_SEARCH_ENGINE_HTTP_ADDRESS); try { System.setProperty(Constants.FESS_SEARCH_ENGINE_HTTP_ADDRESS, "thread-test");Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 17.1K bytes - Click Count (0) -
docs/metrics/prometheus/list.md
|:-----------------------------------------------|:--------------------------------------------------------------------------------------------------------------------------------------------| | `minio_notify_current_send_in_progress` | Number of concurrent async Send calls active to all targets (deprecated, please use `minio_notify_target_current_send_in_progress` instead) |
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 43.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/thumbnail/ThumbnailManagerTest.java
import java.io.File; import java.io.IOException; import java.nio.file.Files; import java.nio.file.Path; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.LinkedBlockingQueue; import org.codelibs.core.misc.Tuple3; import org.codelibs.fess.Constants; import org.codelibs.fess.exception.FessSystemException; import org.codelibs.fess.unit.UnitFessTestCase;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 20.4K bytes - Click Count (0) -
guava/src/com/google/common/collect/AbstractMapBasedMultimap.java
* while adding a new pair. * * <p>This class is not threadsafe when any concurrent operations update the multimap, even if the * underlying map and {@link #createCollection()} method return threadsafe classes. Concurrent read * operations will work correctly. To allow concurrent update operations, wrap your multimap with a * call to {@link Multimaps#synchronizedMultimap}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Nov 17 22:50:48 GMT 2025 - 48.4K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/lock/Smb2LockResponseTest.java
int bytesRead = response.readBytesWireFormat(buffer, bufferIndex); // Then assertEquals(4, bytesRead); } @Test @DisplayName("Should handle concurrent access safely") void testConcurrentAccess() throws InterruptedException { // Given int threadCount = 10; Thread[] threads = new Thread[threadCount];
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 17.1K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import org.slf4j.Logger;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 33.4K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/AbstractMapBasedMultimap.java
* while adding a new pair. * * <p>This class is not threadsafe when any concurrent operations update the multimap, even if the * underlying map and {@link #createCollection()} method return threadsafe classes. Concurrent read * operations will work correctly. To allow concurrent update operations, wrap your multimap with a * call to {@link Multimaps#synchronizedMultimap}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Aug 12 15:51:57 GMT 2025 - 46.9K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbTreeImpl.java
import java.util.Arrays; import java.util.Collections; import java.util.EnumSet; import java.util.LinkedList; import java.util.List; import java.util.Set; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.CIFSContext; import jcifs.CIFSException; import jcifs.DfsReferralData;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 30K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
import java.util.Set; import java.util.concurrent.CancellationException; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReferenceArray; import java.util.concurrent.locks.ReentrantLock; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * The concurrent hash map implementation built by {@link MapMaker}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 89.9K bytes - Click Count (0)