- Sort Score
- Num 10 results
- Language All
Results 451 - 460 of 1,325 for concurrency (0.06 seconds)
-
guava-gwt/test/com/google/common/collect/testing/google/Google.gwt.xml
util.concurrent tests under Guava. The problem is that GWT responds poorly to two .gwt.xml files in the same Java package; see https://groups.google.com/g/google-web-toolkit-contributors/c/CqYH59Dt_rQ/m/uVGW1QdUsXUJ for details. The summary is that it ignores one file in favor of the other. util.concurrent, like nearly all our packages, has two .gwt.xml files: oneCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 19 16:02:36 GMT 2024 - 1.7K bytes - Click Count (0) -
src/main/java/jcifs/util/AuthenticationRateLimiter.java
import java.time.Instant; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; 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;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 15.1K bytes - Click Count (0) -
src/main/java/jcifs/util/ResourceManager.java
import java.util.Collections; import java.util.Map; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; import org.slf4j.Logger; import org.slf4j.LoggerFactory;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 16.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
* or implied. See the License for the specific language governing permissions and limitations under * the License. */ package com.google.common.util.concurrent; import static com.google.common.util.concurrent.NullnessCasts.uncheckedCastNullableTToT; import static com.google.common.util.concurrent.Platform.restoreInterruptIfIsInterruptedException; import com.google.common.annotations.GwtCompatible;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 10K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.Executors.newFixedThreadPool; import com.google.common.annotations.GwtIncompatible;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 8.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.Executors.newFixedThreadPool; import com.google.common.annotations.GwtIncompatible;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 8.4K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/CycleDetectingLockFactoryBenchmark.java
* limitations under the License. */ package com.google.common.util.concurrent; import com.google.caliper.BeforeExperiment; import com.google.caliper.Benchmark; import com.google.caliper.Param; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import org.jspecify.annotations.NullUnmarked; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 2.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
* the License. */ package com.google.common.util.concurrent; import static com.google.common.base.Preconditions.checkNotNull; import static java.util.concurrent.Executors.callable; import com.google.common.annotations.GwtCompatible; import com.google.j2objc.annotations.WeakOuter; import java.util.concurrent.Callable; import java.util.concurrent.RunnableFuture; import org.jspecify.annotations.Nullable; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 5.5K bytes - Click Count (0) -
mockwebserver/api/mockwebserver3.api
public final fun status (Ljava/lang/String;)Lmockwebserver3/MockResponse$Builder; public final fun throttleBody (JJLjava/util/concurrent/TimeUnit;)Lmockwebserver3/MockResponse$Builder; public final fun trailers (Lokhttp3/Headers;)Lmockwebserver3/MockResponse$Builder; public final fun trailersDelay (JLjava/util/concurrent/TimeUnit;)Lmockwebserver3/MockResponse$Builder;
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 11.8K 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)