Search Options

Results per page
Sort
Preferred Languages
Advance

Results 571 - 580 of 966 for concurrency (0.16 sec)

  1. android/guava/src/com/google/common/collect/Multimaps.java

       * {@code factory}, and the multimap contents are all serializable.
       *
       * <p>The multimap is not threadsafe when any concurrent operations update the multimap, even if
       * {@code map} and the instances generated by {@code factory} are. Concurrent read operations will
       * work correctly. To allow concurrent update operations, wrap the multimap with a call to {@link
       * #synchronizedMultimap}.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  2. 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;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  3. 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;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 21 20:53:25 UTC 2024
    - 2.8K bytes
    - Viewed (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
    @ElementTypesAreNonnullByDefault
    public enum RemovalCause {
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 15 18:00:07 UTC 2021
    - 2.7K bytes
    - Viewed (0)
  5. .github/ISSUE_TEMPLATE/bug_report.yaml

            - com.google.common.math
            - com.google.common.net
            - com.google.common.primitives
            - com.google.common.reflect
            - com.google.common.testing
            - com.google.common.util.concurrent
    
      - type: dropdown
        attributes:
          label: Platforms
          description: If this issue is platform-specific, then please select the relevant platforms.
          multiple: true
          options:
            - Android
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 16 20:08:25 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskLogger.kt

     * 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 okhttp3.internal.concurrent
    
    import java.util.logging.Level
    import java.util.logging.Logger
    
    internal inline fun Logger.taskLog(
      task: Task,
      queue: TaskQueue,
      messageBlock: () -> String,
    ) {
      if (isLoggable(Level.FINE)) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/eventbus/AsyncEventBus.java

     * or implied. See the License for the specific language governing permissions and limitations under
     * the License.
     */
    
    package com.google.common.eventbus;
    
    import java.util.concurrent.Executor;
    
    /**
     * An {@link EventBus} that takes the Executor of your choice and uses it to dispatch events,
     * allowing dispatch to occur asynchronously.
     *
     * @author Cliff Biffle
     * @since 10.0
     */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

    import java.net.UnknownHostException;
    import java.util.Arrays;
    import java.util.Comparator;
    import java.util.LinkedList;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentLinkedQueue;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.Address;
    import jcifs.CIFSContext;
    import jcifs.CIFSException;
    import jcifs.SmbConstants;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Dec 20 14:09:34 UTC 2020
    - 12.5K bytes
    - Viewed (0)
  9. docs/features/connections.md

    Since version 5.0, `OkHttpClient` supports fast fallback, which is our implementation of Happy Eyeballs [RFC 6555](https://datatracker.ietf.org/doc/html/rfc6555).
    
    With fast fallback, OkHttp attempts to connect to multiple web servers concurrently. It keeps whichever route connects first and cancels all of the others. Its rules are:
    
     * Prefer to alternate IP addresses from different address families, (IPv6 / IPv4), starting with IPv6.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  10. prepare_stmt.go

    			return Stmt{}, stmt.prepareErr
    		}
    
    		return *stmt, nil
    	}
    	// check db.Stmts first to avoid Segmentation Fault(setting value to nil map)
    	// which cause by calling Close and executing SQL concurrently
    	if db.Stmts == nil {
    		db.Mux.Unlock()
    		return Stmt{}, ErrInvalidDB
    	}
    	// cache preparing stmt first
    	cacheStmt := Stmt{Transaction: isTransaction, prepared: make(chan struct{})}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top