- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 1,033 for concurrent (0.05 seconds)
-
docs/en/docs/async.md
### Concurrent Burgers { #concurrent-burgers } You go with your crush to get fast food, you stand in line while the cashier takes the orders from the people in front of you. π <img src="/img/async/concurrent-burgers/concurrent-burgers-01.png" class="illustration"> Then it's your turn, you place your order of 2 very fancy burgers for your crush and you. ππCreated: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 23.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/rank/fusion/RankFusionProcessorConcurrencyTest.java
import java.util.HashMap; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import org.apache.lucene.search.TotalHits.Relation; import org.codelibs.fess.entity.FacetInfo;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 13.5K bytes - Click Count (0) -
cmd/http-tracer_test.go
// - Read operations via toServerHTTPStats(false). func TestRaulStatsRaceCondition(t *testing.T) { httpStats := newHTTPStats() // Simulate the concurrent scenario from the original race condition: // Multiple HTTP request handlers updating stats concurrently, // while background processes are reading the stats for persistence. const numWriters = 100 // Simulate many HTTP request handlers.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.3K bytes - Click Count (0) -
guava/src/com/google/common/collect/MapMaker.java
} /** * 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 * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 12.8K bytes - Click Count (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcConstants.java
/** * Reserved flag for future use */ int DCERPC_RESERVED_1 = 0x08; /** * Supports concurrent multiplexing flag */ int DCERPC_CONC_MPX = 0x10; /* supports concurrent multiplexing */ /** * Did not execute flag - indicates request was not executed */ int DCERPC_DID_NOT_EXECUTE = 0x20; /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 2.2K bytes - Click Count (0) -
internal/event/targetlist.go
CurrentSendCalls int64 // CurrentSendCalls is the number of concurrent async Send calls to all targets CurrentQueue int // Populated if target has a store. TotalEvents int64 FailedEvents int64 // Number of failed events per target } // TargetList - holds list of targets indexed by target ID. type TargetList struct { // The number of concurrent async Send calls to all targets currentSendCalls atomic.Int64Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 9.2K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/Smb2EncryptionContextTest.java
import java.util.Arrays; import java.util.HashSet; import java.util.List; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.DisplayName;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 44.1K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/LongAdder.java
public void decrement() { add(-1L); } /** * Returns the current sum. The returned value is NOT an atomic snapshot; invocation in * the absence of concurrent updates returns an accurate result, but concurrent updates that occur * while the sum is being calculated might not be incorporated. * * @return the sum */ @Override public long sum() { long sum = base;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 5.6K bytes - Click Count (0) -
docs/ko/docs/async.md
<img src="/img/async/concurrent-burgers/concurrent-burgers-01.png" class="illustration"> μ΄μ μ¬λ¬λΆ μ°¨λ‘κ° λμ΄, μ¬λ¬λΆκ³Ό μ§μ¬λ μλλ₯Ό μν΄ λ§€μ° κ³ κΈμ€λ¬μ΄ νλ²κ±° 2κ°λ₯Ό μ£Όλ¬Έν©λλ€. ππ <img src="/img/async/concurrent-burgers/concurrent-burgers-02.png" class="illustration"> μ μμ μ£Όλ°©μ μ리μ¬μκ² λ¬΄μΈκ°λ₯Ό λ§ν΄, (μ§κΈμ μμ μλλ€μ μ£Όλ¬Έμ μ€λΉνκ³ μλλΌλ) μ¬λ¬λΆμ νλ²κ±°λ₯Ό μ€λΉν΄μΌ νλ€λ κ²μ μκ² ν©λλ€. <img src="/img/async/concurrent-burgers/concurrent-burgers-03.png" class="illustration"> μ¬λ¬λΆμ΄ λμ λ λλ€. πΈ
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 14:06:26 GMT 2026 - 27.5K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/HashMultimap.java
* views are modifiable. * * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent * read operations will work correctly if the last write <i>happens-before</i> any reads. To allow * concurrent update operations, wrap your multimap with a call to {@link * Multimaps#synchronizedSetMultimap}. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 05 23:15:58 GMT 2025 - 5.8K bytes - Click Count (0)