Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1921 - 1930 of 3,610 for Signal (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. benchmarks/src/main/java/org/elasticsearch/benchmark/routing/allocation/Allocators.java

    import java.util.Collection;
    import java.util.Collections;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.atomic.AtomicInteger;
    
    public final class Allocators {
        private static class NoopGatewayAllocator extends GatewayAllocator {
            public static final NoopGatewayAllocator INSTANCE = new NoopGatewayAllocator();
    
            @Override
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Feb 03 00:10:53 GMT 2021
    - 3.9K bytes
    - Click Count (0)
  2. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/upgrades/UpgradedProperties.java

    public class UpgradedProperties {
    
        private static final Pattern SETTER_REGEX = Pattern.compile("set[A-Z].*");
        private static final Pattern GETTER_REGEX = Pattern.compile("get[A-Z].*");
        private static final Pattern BOOLEAN_GETTER_REGEX = Pattern.compile("is[A-Z].*");
        public static final String OLD_REMOVED_ACCESSORS_OF_UPGRADED_PROPERTIES = "oldRemovedAccessorsOfUpgradedProperties";
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Wed Dec 24 14:15:15 GMT 2025
    - 9.3K bytes
    - Click Count (0)
  3. samples/guide/src/main/java/okhttp3/recipes/CustomTrust.java

    import okhttp3.Headers;
    import okhttp3.OkHttpClient;
    import okhttp3.Request;
    import okhttp3.Response;
    import okhttp3.tls.Certificates;
    import okhttp3.tls.HandshakeCertificates;
    
    public final class CustomTrust {
      // PEM files for root certificates of Comodo and Entrust. These two CAs are sufficient to view
      // https://publicobject.com (Comodo) and https://squareup.com (Entrust). But they aren't
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Aug 12 07:26:27 GMT 2021
    - 9.3K bytes
    - Click Count (0)
  4. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultGraphConflictResolver.java

                return null; // no edges - nothing to worry about
            }
    
            final TreeSet<MetadataGraphVertex> vertices = graph.getVertices();
    
            try {
                // edge case - single vertex graph
                if (vertices.size() == 1) {
                    return new MetadataGraph(entry);
                }
    
                final ArtifactScopeEnum requestedScope = ArtifactScopeEnum.checkScope(scope);
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jul 23 17:27:08 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  5. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/RegularImmutableSortedSet.java

    import java.util.SortedSet;
    
    /**
     * GWT emulation of {@link RegularImmutableSortedSet}.
     *
     * @author Hayward Chan
     */
    final class RegularImmutableSortedSet<E> extends ImmutableSortedSet<E> {
      /** true if this set is a subset of another immutable sorted set. */
      final boolean isSubset;
    
      RegularImmutableSortedSet(SortedSet<E> delegate, boolean isSubset) {
        super(delegate);
        this.isSubset = isSubset;
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Jul 01 22:23:20 GMT 2025
    - 1.2K bytes
    - Click Count (0)
  6. guava/src/com/google/common/cache/LongAddables.java

    /**
     * Source of {@link LongAddable} objects that deals with GWT and all that.
     *
     * @author Louis Wasserman
     */
    @GwtCompatible
    final class LongAddables {
      public static LongAddable create() {
        return new JavaUtilConcurrentLongAdder();
      }
    
      private static final class JavaUtilConcurrentLongAdder extends LongAdder implements LongAddable {}
    
      private LongAddables() {}
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Aug 10 19:54:19 GMT 2025
    - 1.1K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/collect/EmptyContiguousSet.java

        return true;
      }
    
      @Override
      public int hashCode() {
        return 0;
      }
    
      @GwtIncompatible
      @J2ktIncompatible
      private static final class SerializedForm<C extends Comparable> implements Serializable {
        private final DiscreteDomain<C> domain;
    
        private SerializedForm(DiscreteDomain<C> domain) {
          this.domain = domain;
        }
    
        private Object readResolve() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  8. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/PhaseId.java

        /**
         * Interned {@link PhaseId} instances.
         */
        private static final Map<String, PhaseId> INSTANCES = new WeakHashMap<>();
    
        /**
         * The execution point of this {@link PhaseId}.
         */
        private final PhaseExecutionPoint executionPoint;
    
        /**
         * The static phase that this dynamic phase belongs to.
         */
        private final String phase;
    
        /**
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

        outer.add("foo"); // necessary because we try to remove elements later on
        return outer;
      }
    
      private static final class TestDeque<E> implements Deque<E> {
        private final Deque<E> delegate = new LinkedList<>();
        private final Object mutex = new Object[0]; // something Serializable
    
        @Override
        public boolean offer(E o) {
          assertTrue(Thread.holdsLock(mutex));
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        return t.getState() == Thread.State.WAITING && blocker.isInstance(LockSupport.getBlocker(t));
      }
    
      static final class SlowChannel extends AbstractInterruptibleChannel {
        final CountDownLatch exitClose = new CountDownLatch(1);
    
        @Override
        protected void implCloseChannel() {
          Uninterruptibles.awaitUninterruptibly(exitClose);
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
Back to Top