Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 451 - 460 of 1,325 for concurrency (0.36 seconds)

  1. 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: one
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 19 16:02:36 GMT 2024
    - 1.7K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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.Int64
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 9.2K bytes
    - Click Count (0)
Back to Top