Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 861 - 870 of 1,335 for concurrent (0.07 seconds)

  1. android/guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.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 java.util.logging.Level.SEVERE;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.annotations.VisibleForTesting;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 10 21:03:40 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  2. guava-testlib/src/com/google/common/testing/TestLogHandler.java

     * limitations under the License.
     */
    
    package com.google.common.testing;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.errorprone.annotations.concurrent.GuardedBy;
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.List;
    import java.util.logging.Handler;
    import java.util.logging.LogRecord;
    import org.jspecify.annotations.NullMarked;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2.8K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/ForwardingObjectTester.java

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static org.mockito.Answers.CALLS_REAL_METHODS;
    import static org.mockito.Mockito.doReturn;
    import static org.mockito.Mockito.mock;
    
    import com.google.common.annotations.GwtIncompatible;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 2.8K bytes
    - Click Count (0)
  4. guava/src/com/google/common/cache/RemovalCause.java

     * the License.
     */
    
    package com.google.common.cache;
    
    import com.google.common.annotations.GwtCompatible;
    import java.util.Iterator;
    import java.util.Map;
    import java.util.concurrent.ConcurrentMap;
    
    /**
     * The reason why a cached entry was removed.
     *
     * @author Charles Fry
     * @since 10.0
     */
    @GwtCompatible
    public enum RemovalCause {
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 2.7K bytes
    - Click Count (0)
  5. benchmarks/src/main/java/org/elasticsearch/benchmark/fs/AvailableIndexFoldersBenchmark.java

    import org.openjdk.jmh.annotations.Warmup;
    
    import java.io.IOException;
    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.util.HashSet;
    import java.util.Set;
    import java.util.concurrent.TimeUnit;
    
    @Warmup(iterations = 5, time = 1, timeUnit = TimeUnit.SECONDS)
    @Measurement(iterations = 5, time = 1, timeUnit = TimeUnit.SECONDS)
    @Fork(3)
    @BenchmarkMode(Mode.AverageTime)
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Apr 27 15:29:12 GMT 2021
    - 3K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/internal.kt

    import okhttp3.Headers
    import okhttp3.HttpUrl
    import okhttp3.MediaType
    import okhttp3.MediaType.Companion.toMediaTypeOrNull
    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.Response
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.ConnectionListener
    import okhttp3.internal.connection.RealConnection
    
    // Exposes Kotlin-internal APIs to Java test code and code in other modules.
    
    internal fun parseCookie(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 3.8K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt

     */
    package okhttp3.internal.http2
    
    import java.io.Closeable
    import java.io.IOException
    import java.util.logging.Level.FINE
    import java.util.logging.Logger
    import okhttp3.internal.concurrent.Lockable
    import okhttp3.internal.concurrent.withLock
    import okhttp3.internal.format
    import okhttp3.internal.http2.Http2.CONNECTION_PREFACE
    import okhttp3.internal.http2.Http2.FLAG_ACK
    import okhttp3.internal.http2.Http2.FLAG_END_HEADERS
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 11K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

    import java.net.Socket
    import java.net.SocketTimeoutException
    import java.nio.charset.Charset
    import java.util.Collections
    import java.util.Locale
    import java.util.TimeZone
    import java.util.concurrent.ThreadFactory
    import java.util.concurrent.TimeUnit
    import kotlin.text.Charsets.UTF_16BE
    import kotlin.text.Charsets.UTF_16LE
    import kotlin.text.Charsets.UTF_32BE
    import kotlin.text.Charsets.UTF_32LE
    import kotlin.text.Charsets.UTF_8
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10.3K bytes
    - Click Count (1)
  9. android/guava-testlib/src/com/google/common/collect/testing/TestsForMapsInJavaUtil.java

    import java.util.Hashtable;
    import java.util.LinkedHashMap;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.SortedMap;
    import java.util.TreeMap;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentSkipListMap;
    import junit.framework.Test;
    import junit.framework.TestSuite;
    
    /**
     * Generates a test suite covering the {@link Map} implementations in the {@link java.util} package.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Dec 16 03:23:31 GMT 2025
    - 17.3K bytes
    - Click Count (0)
  10. android/guava-testlib/src/com/google/common/collect/testing/testers/ConcurrentMapRemoveTester.java

    import com.google.common.collect.testing.AbstractMapTester;
    import com.google.common.collect.testing.features.CollectionSize;
    import com.google.common.collect.testing.features.MapFeature;
    import java.util.concurrent.ConcurrentMap;
    import org.jspecify.annotations.NullMarked;
    import org.junit.Ignore;
    
    /**
     * Tester for {@link ConcurrentMap#remove}. Can't be invoked directly; please see {@link
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 14:50:24 GMT 2024
    - 4K bytes
    - Click Count (0)
Back to Top