Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 541 - 550 of 830 for concurrent (0.05 seconds)

  1. guava/src/com/google/common/eventbus/Subscriber.java

    import com.google.common.annotations.VisibleForTesting;
    import com.google.j2objc.annotations.Weak;
    import java.lang.reflect.InvocationTargetException;
    import java.lang.reflect.Method;
    import java.util.concurrent.Executor;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A subscriber method on a specific object, plus the executor that should be used for dispatching
     * events to it.
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  2. cmd/background-heal-ops.go

    type healRoutine struct {
    	tasks   chan healTask
    	workers int
    }
    
    func activeListeners() int {
    	// Bucket notification and http trace are not costly, it is okay to ignore them
    	// while counting the number of concurrent connections
    	return int(globalHTTPListen.Subscribers()) + int(globalTrace.Subscribers())
    }
    
    func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) {
    	// No need to wait run at full speed.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  3. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt

     * limitations under the License.
     */
    package okhttp3.sse.internal
    
    import assertk.assertThat
    import assertk.assertions.containsExactly
    import assertk.assertions.isEqualTo
    import java.util.concurrent.TimeUnit
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.junit5.StartStop
    import okhttp3.CallEvent.CallEnd
    import okhttp3.CallEvent.CallStart
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  4. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

    import java.security.SecureRandom
    import java.security.Security
    import java.security.cert.Certificate
    import java.security.cert.CertificateException
    import java.security.cert.X509Certificate
    import java.util.concurrent.atomic.AtomicInteger
    import java.util.logging.Handler
    import java.util.logging.Level
    import java.util.logging.LogRecord
    import java.util.logging.Logger
    import javax.net.ssl.HostnameVerifier
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 29.9K bytes
    - Click Count (0)
  5. build-logic/cleanup/src/test/groovy/gradlebuild/cleanup/services/LeakingProcessKillPatternTest.groovy

    lang=ALL-UNNAMED --add-opens=java.base/java.lang.invoke=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-opens=java.base/java.nio.charset=ALL-UNNAMED --add-opens=java.base/java.net=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED -Xms256m -Xmx1024m -Dfile.encoding=UTF-8 -Djava.io.tmpdir=C:\\tcagent1\\work\\f63322e10dd6b396\\subprojects\\launcher\\build\\tmp -Duser.country=US -Duser.language=en -Duser.variant -ea -cp "C:\\tcagent1\\work\\f63322e10dd6b3...
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Fri Jul 12 03:42:46 GMT 2024
    - 14.8K bytes
    - Click Count (0)
  6. okhttp-tls/api/okhttp-tls.api

    	public final fun certificateAuthority (I)Lokhttp3/tls/HeldCertificate$Builder;
    	public final fun commonName (Ljava/lang/String;)Lokhttp3/tls/HeldCertificate$Builder;
    	public final fun duration (JLjava/util/concurrent/TimeUnit;)Lokhttp3/tls/HeldCertificate$Builder;
    	public final fun ecdsa256 ()Lokhttp3/tls/HeldCertificate$Builder;
    	public final fun keyPair (Ljava/security/KeyPair;)Lokhttp3/tls/HeldCertificate$Builder;
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Feb 26 19:17:33 GMT 2022
    - 3.7K bytes
    - Click Count (0)
  7. guava/src/com/google/common/collect/AbstractSortedMultiset.java

     */
    
    package com.google.common.collect;
    
    import static com.google.common.base.Preconditions.checkNotNull;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import com.google.j2objc.annotations.WeakOuter;
    import java.util.Comparator;
    import java.util.Iterator;
    import java.util.NavigableSet;
    import org.jspecify.annotations.Nullable;
    
    /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/resident/ResidentMavenInvoker.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.cling.invoker.mvn.resident;
    
    import java.util.ArrayList;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.function.Consumer;
    
    import org.apache.maven.api.annotations.Nullable;
    import org.apache.maven.api.cli.InvokerException;
    import org.apache.maven.api.cli.InvokerRequest;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Sep 11 17:20:46 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  9. guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static java.lang.Math.min;
    import static java.util.concurrent.TimeUnit.SECONDS;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.math.LongMath;
    import java.util.concurrent.TimeUnit;
    
    @J2ktIncompatible
    @GwtIncompatible
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 19.3K bytes
    - Click Count (0)
  10. .teamcity/test-buckets.json

              "test-suites-base",
              "testing-jvm"
            ],
            "parallelizationMethod": {
              "name": "TestDistribution"
            }
          },
          {
            "subprojects": [
              "concurrent",
              "daemon-protocol",
              "daemon-server-worker",
              "functional",
              "internal-instrumentation-api",
              "java-api-extractor",
              "java-compiler-plugin",
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Fri Aug 01 00:23:04 GMT 2025
    - 119.4K bytes
    - Click Count (0)
Back to Top