Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 261 - 270 of 327 for Synchronized (0.09 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/CipherSuite.kt

         * @param javaName the name used by Java APIs for this cipher suite. Different than the IANA
         *     name for older cipher suites because the prefix is `SSL_` instead of `TLS_`.
         */
        @JvmStatic
        @Synchronized fun forJavaName(javaName: String): CipherSuite {
          var result: CipherSuite? = INSTANCES[javaName]
          if (result == null) {
            result = INSTANCES[secondaryName(javaName)]
    
            if (result == null) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 39.9K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

              }
            }
          }
        clientListener.setNextEventDelegate(reconnectOnFailure)
        webSockets.add(client.newWebSocket(request, clientListener))
        attempts.await()
        synchronized(webSockets) {
          for (webSocket in webSockets) {
            webSocket.cancel()
          }
        }
      }
    
      @Test
      @Throws(Exception::class)
      fun compressedMessages() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 35.5K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

            if (logger.isDebugEnabled()) {
                logger.debug("Registering searcher: {}", searcher.getClass().getSimpleName());
            }
            searchers.add(searcher);
            synchronized (this) {
                if (executorService == null) {
                    int numThreads = ComponentUtil.getFessConfig().getRankFusionThreadsAsInteger();
                    if (numThreads <= 0) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Dec 25 02:13:14 GMT 2025
    - 28K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

    import java.util.concurrent.Future;
    import java.util.concurrent.atomic.AtomicReference;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Serializes execution of tasks, somewhat like an "asynchronous {@code synchronized} block." Each
     * {@linkplain #submit enqueued} callable will not be submitted to its associated executor until the
     * previous callable has returned -- and, if the previous callable was an {@link AsyncCallable}, not
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 22.1K bytes
    - Click Count (0)
  5. guava/src/com/google/common/collect/ArrayTable.java

     * methods for more details.
     *
     * <p>Note that this implementation is not synchronized. If multiple threads access the same cell of
     * an {@code ArrayTable} concurrently and one of the threads modifies its value, there is no
     * guarantee that the new value will be fully visible to the other threads. To guarantee that
     * modifications are visible, synchronize access to the table. Unlike other {@code Table}
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Mar 08 16:16:42 GMT 2026
    - 26.9K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/ImmutableList.java

       * {@code ImmutableList.of(list)} returns an {@code ImmutableList<List<String>>} containing one
       * element (the given list itself).
       *
       * <p>This method is safe to use even when {@code elements} is a synchronized or concurrent
       * collection that is currently being modified by another thread.
       *
       * @throws NullPointerException if {@code elements} contains a null element
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 27.5K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/collect/SynchronizedNavigableMapTest.java

     */
    
    package com.google.common.collect;
    
    import static com.google.common.truth.Truth.assertThat;
    
    import com.google.common.collect.Synchronized.SynchronizedNavigableMap;
    import com.google.common.collect.Synchronized.SynchronizedNavigableSet;
    import com.google.common.collect.Synchronized.SynchronizedSortedMap;
    import com.google.common.collect.testing.NavigableMapTestSuiteBuilder;
    import com.google.common.collect.testing.SafeTreeMap;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 12.8K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb/NtlmPasswordAuthenticator.java

                case 2:
                    md4.update(ntHash);
                    md4.digest(dest, offset, 16);
                    break;
                case 3:
                case 4:
                case 5:
                    synchronized (this) {
                        if (this.clientChallenge == null) {
                            this.clientChallenge = new byte[8];
                            tc.getConfig().getRandom().nextBytes(this.clientChallenge);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 30.3K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

          } finally {
            add(newCloseables, directExecutor());
          }
        }
    
        @Override
        public void close() {
          if (closed) {
            return;
          }
          synchronized (this) {
            if (closed) {
              return;
            }
            closed = true;
          }
          for (Map.Entry<AutoCloseable, Executor> entry : entrySet()) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 101.7K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/collect/ArrayTable.java

     * methods for more details.
     *
     * <p>Note that this implementation is not synchronized. If multiple threads access the same cell of
     * an {@code ArrayTable} concurrently and one of the threads modifies its value, there is no
     * guarantee that the new value will be fully visible to the other threads. To guarantee that
     * modifications are visible, synchronize access to the table. Unlike other {@code Table}
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Aug 13 19:39:21 GMT 2025
    - 26.2K bytes
    - Click Count (0)
Back to Top