Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 425 for Unsafe (0.04 seconds)

  1. ci/official/utilities/setup.sh

      echo 'If you have not, you will see a lot of undefined variable errors.'
    else
      FROM_ENV=$(mktemp)
      # "export -p" prints a list of environment values in a safe-to-source format,
      # e.g. `declare -x TFCI_BAZEL_COMMON_ARGS="list of args"` for bash.
      export -p | grep TFCI > "$FROM_ENV"
    
      # Source the default ci values
      source ./ci/official/envs/ci_default
    
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Thu Jan 09 18:37:25 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt

    import okio.Buffer
    import okio.BufferedSource
    import okio.ByteString
    
    /**
     * An [RFC 6455][rfc_6455]-compatible WebSocket frame reader.
     *
     * This class is not thread safe.
     *
     * [rfc_6455]: http://tools.ietf.org/html/rfc6455
     */
    class WebSocketReader(
      private val isClient: Boolean,
      val source: BufferedSource,
      private val frameCallback: FrameCallback,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 16:11:23 GMT 2025
    - 10K bytes
    - Click Count (0)
  3. guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

            queue.add(event, label);
          }
        }
      }
    
      /**
       * Dispatches all events enqueued prior to this call, serially and in order, for every listener.
       *
       * <p>Note: this method is idempotent and safe to call from any thread
       */
      public void dispatch() {
        // iterate by index to avoid concurrent modification exceptions
        for (int i = 0; i < listeners.size(); i++) {
          listeners.get(i).dispatch();
        }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

            queue.add(event, label);
          }
        }
      }
    
      /**
       * Dispatches all events enqueued prior to this call, serially and in order, for every listener.
       *
       * <p>Note: this method is idempotent and safe to call from any thread
       */
      public void dispatch() {
        // iterate by index to avoid concurrent modification exceptions
        for (int i = 0; i < listeners.size(); i++) {
          listeners.get(i).dispatch();
        }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/ContiguousSet.java

          throw new IllegalArgumentException(e);
        }
    
        boolean empty;
        if (effectiveRange.isEmpty()) {
          empty = true;
        } else {
          /*
           * requireNonNull is safe because the effectiveRange operations above would have thrown or
           * effectiveRange.isEmpty() would have returned true.
           */
          C afterLower = requireNonNull(range.lowerBound.leastValueAbove(domain));
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/Queues.java

            }
          }
        } finally {
          if (interrupted) {
            Thread.currentThread().interrupt();
          }
        }
        return added;
      }
    
      /**
       * Returns a synchronized (thread-safe) queue backed by the specified queue. In order to guarantee
       * serial access, it is critical that <b>all</b> access to the backing queue is accomplished
       * through the returned queue.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Nov 04 17:24:58 GMT 2025
    - 18K bytes
    - Click Count (0)
  7. internal/lru/lru.go

    import (
    	"sync"
    	"time"
    )
    
    // EvictCallback is used to get a callback when a cache entry is evicted
    type EvictCallback[K comparable, V any] func(key K, value V)
    
    // LRU implements a thread-safe LRU with expirable entries.
    type LRU[K comparable, V any] struct {
    	size      int
    	evictList *LruList[K, V]
    	items     map[K]*Entry[K, V]
    	onEvict   EvictCallback[K, V]
    
    	// expirable options
    	mu   sync.Mutex
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

     * Unlike many other double-ended priority queues, it stores elements in a single array, as compact
     * as the traditional heap data structure used in {@link PriorityQueue}.
     *
     * <p>This class is not thread-safe, and does not accept null elements.
     *
     * <p><i>Performance notes:</i>
     *
     * <ul>
     *   <li>If you only access one end of the queue, and do use a maximum size, this class will perform
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 33.9K bytes
    - Click Count (0)
  9. guava/src/com/google/common/graph/ImmutableGraph.java

       *         .putEdge(FRANCE, BELGIUM)
       *         .putEdge(GERMANY, BELGIUM)
       *         .addNode(ICELAND)
       *         .build();
       * }
       *
       * <p>Builder instances can be reused; it is safe to call {@link #build} multiple times to build
       * multiple graphs in series. Each new graph contains all the elements of the ones created before
       * it.
       *
       * @since 28.0
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/base/OptionalTest.java

        FluentIterable<? extends Number> numbers = getSomeNumbers();
    
        // Sadly, the following is what users will have to do in some circumstances.
    
        @SuppressWarnings("unchecked") // safe covariant cast
        Optional<Number> first = (Optional<Number>) numbers.first();
        Number value = first.or(0.5); // fine
      }
    
      @J2ktIncompatible
      @GwtIncompatible // NullPointerTester
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 10.5K bytes
    - Click Count (0)
Back to Top