Search Options

Results per page
Sort
Preferred Languages
Advance

Results 471 - 480 of 609 for killed (0.12 sec)

  1. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

         * nextItem holds on to item fields because once we claim that an element exists in hasNext(),
         * we must return it in the following next() call even if it was in the process of being removed
         * when hasNext() was called.
         */
        private @Nullable E nextItem;
    
        /**
         * Index of element returned by most recent call to next. Reset to -1 if this element is deleted
         * by a call to remove.
         */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 19 19:24:36 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  2. docs/en/docs/tutorial/bigger-applications.md

    You can think of `APIRouter` as a "mini `FastAPI`" class.
    
    All the same options are supported.
    
    All the same `parameters`, `responses`, `dependencies`, `tags`, etc.
    
    /// tip
    
    In this example, the variable is called `router`, but you can name it however you want.
    
    ///
    
    We are going to include this `APIRouter` in the main `FastAPI` app, but first, let's check the dependencies and another `APIRouter`.
    
    ## Dependencies
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  3. docs/en/docs/tutorial/response-model.md

    ```JSON
    {
        "name": "Foo",
        "price": 50.2
    }
    ```
    
    /// info
    
    In Pydantic v1 the method was called `.dict()`, it was deprecated (but still supported) in Pydantic v2, and renamed to `.model_dump()`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  4. cmd/metacache-stream.go

    	if w == nil || w.closer == nil {
    		return nil
    	}
    	w.streamWg.Wait()
    	err := w.closer()
    	w.closer = nil
    	return err
    }
    
    // Reset and start writing to new writer.
    // Close must have been called before this.
    func (w *metacacheWriter) Reset(out io.Writer) {
    	w.streamErr = nil
    	w.creator = func() error {
    		s2w := s2.NewWriter(out, s2.WriterBlockSize(w.blockSize), s2.WriterConcurrency(2))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/MapMakerInternalMap.java

        /**
         * Returns the current value being referenced, or {@code null} if there is none (e.g. because
         * either it got collected, or {@link #clear} was called, or it wasn't set in the first place).
         */
        @CheckForNull
        V get();
    
        /** Returns the entry which contains this {@link WeakValueReference}. */
        E getEntry();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  6. internal/grid/connection.go

    	c.writeStream(ctx, conn, cancel)
    }
    
    // readStream handles the read side of the connection.
    // It will read messages and send them to c.handleMsg.
    // If an error occurs the cancel function will be called and conn be closed.
    // The function will block until the connection is closed or an error occurs.
    func (c *Connection) readStream(ctx context.Context, conn net.Conn, cancel context.CancelCauseFunc) {
    	defer func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  7. apache-maven/src/main/appended-resources/licenses/CDDL+GPLv2-with-classpath-exception.txt

    Exception could therefore effectively compromise your ability to
    further distribute the package.
    
    Proceed with caution and we recommend that you obtain the advice of a
    lawyer skilled in open source matters before removing the Classpath
    Exception or making modifications to this package which may
    subsequently be redistributed and/or involve the use of third party
    software.
    
    CLASSPATH EXCEPTION
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri May 17 19:14:22 UTC 2024
    - 38.5K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/Sets.java

       * add()} and {@code addAll()} methods throw an {@link IllegalArgumentException}. When methods
       * such as {@code removeAll()} and {@code clear()} are called on the filtered set, only elements
       * that satisfy the filter will be removed from the underlying set.
       *
       * <p>The returned set isn't threadsafe or serializable, even if {@code unfiltered} is.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

     * number types; reasonable default instance for other stateless types. For mutable types, a fresh
     * instance is created each time {@code get()} is called.
     *
     * @author Kevin Bourrillion
     * @author Ben Yu
     * @since 12.0
     */
    @GwtIncompatible
    @J2ktIncompatible
    @ElementTypesAreNonnullByDefault
    public final class ArbitraryInstances {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  10. cmd/metrics-resource.go

    }
    
    // Describe sends the super-set of all possible descriptors of metrics
    func (c *minioResourceCollector) Describe(ch chan<- *prometheus.Desc) {
    	ch <- c.desc
    }
    
    // Collect is called by the Prometheus registry when collecting metrics.
    func (c *minioResourceCollector) Collect(out chan<- prometheus.Metric) {
    	var wg sync.WaitGroup
    	publish := func(in <-chan MetricV2) {
    		defer wg.Done()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
Back to top