- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 932 for CONCURRENT (0.05 seconds)
-
docs/en/docs/async.md
To see the difference, imagine the following story about burgers: ### 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">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) -
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) -
cmd/http-tracer_test.go
// - Write operations via updateStats. // - 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.
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) -
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) -
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) -
guava/src/com/google/common/collect/MapMaker.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.lang.ref.WeakReference; import java.util.ConcurrentModificationException; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import org.jspecify.annotations.Nullable; /** * A builder of {@link ConcurrentMap} instances that can have keys or values automatically wrappedCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 12.8K bytes - Click Count (0) -
docs/ko/docs/async.md
<img src="/img/async/concurrent-burgers/concurrent-burgers-05.png" class="illustration"> ๊ธฐ๋ค๋ฆฌ๋ฉฐ ๋ํํ๋ ๋์, ๋๋๋ก ์ฌ๋ฌ๋ถ์ ์นด์ดํฐ์ ํ์๋๋ ๋ฒํธ๋ฅผ ํ์ธํด ์ฌ๋ฌ๋ถ ์ฐจ๋ก์ธ์ง ๋ด ๋๋ค. ๊ทธ๋ฌ๋ค ์ด๋ ์๊ฐ ๋ง์นจ๋ด ์ฌ๋ฌ๋ถ ์ฐจ๋ก๊ฐ ๋ฉ๋๋ค. ์ฌ๋ฌ๋ถ์ ์นด์ดํฐ์ ๊ฐ์ ํ๋ฒ๊ฑฐ๋ฅผ ๋ฐ๊ณ , ํ ์ด๋ธ๋ก ๋์์ต๋๋ค. <img src="/img/async/concurrent-burgers/concurrent-burgers-06.png" class="illustration"> ์ฌ๋ฌ๋ถ๊ณผ ์ง์ฌ๋ ์๋๋ ํ๋ฒ๊ฑฐ๋ฅผ ๋จน์ผ๋ฉฐ ์ข์ ์๊ฐ์ ๋ณด๋ ๋๋ค. โจ <img src="/img/async/concurrent-burgers/concurrent-burgers-07.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/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) -
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)