Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 444 for Queues (0.05 seconds)

  1. internal/s3select/json/preader.go

    	r.bufferPool.New = func() []byte {
    		return make([]byte, jsonSplitSize+1024)
    	}
    
    	// Create queue
    	r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.input = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.readerWg.Add(1)
    
    	// Start splitter
    	go func() {
    		defer close(r.input)
    		defer close(r.queue)
    		defer r.readerWg.Done()
    		for {
    			next, err := r.nextSplit(jsonSplitSize, r.bufferPool.Get())
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  2. docs/es/docs/tutorial/index.md

    Si no quieres tener esas dependencias opcionales, en su lugar puedes instalar `pip install fastapi`.
    
    Si quieres instalar las dependencias estándar pero sin `fastapi-cloud-cli`, puedes instalar con `pip install "fastapi[standard-no-fastapi-cloud-cli]"`.
    
    ///
    
    /// tip | Consejo
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 5.6K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/base/FinalizableWeakReference.java

      /**
       * Constructs a new finalizable weak reference.
       *
       * @param referent to weakly reference
       * @param queue that should finalize the referent
       */
      protected FinalizableWeakReference(@Nullable T referent, FinalizableReferenceQueue queue) {
        super(referent, queue.queue);
        queue.cleanUp();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  4. guava/src/com/google/common/base/FinalizableWeakReference.java

      /**
       * Constructs a new finalizable weak reference.
       *
       * @param referent to weakly reference
       * @param queue that should finalize the referent
       */
      protected FinalizableWeakReference(@Nullable T referent, FinalizableReferenceQueue queue) {
        super(referent, queue.queue);
        queue.cleanUp();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

      }
    
      private void enqueueHelper(Event<L> event, Object label) {
        checkNotNull(event, "event");
        checkNotNull(label, "label");
        synchronized (listeners) {
          for (PerListenerQueue<L> queue : listeners) {
            queue.add(event, label);
          }
        }
      }
    
      /**
       * Dispatches all events enqueued prior to this call, serially and in order, for every listener.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  6. cmd/site-replication-metrics_gen.go

    			}
    		case "ReplicaCount":
    			z.ReplicaCount, err = dc.ReadInt64()
    			if err != nil {
    				err = msgp.WrapError(err, "ReplicaCount")
    				return
    			}
    		case "Queued":
    			err = z.Queued.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Queued")
    				return
    			}
    		case "Proxied":
    			err = z.Proxied.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Proxied")
    				return
    			}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 40.3K bytes
    - Click Count (0)
  7. docs/es/docs/environment-variables.md

    Las variables de entorno pueden ser útiles para manejar **configuraciones** de aplicaciones, como parte de la **instalación** de Python, etc.
    
    ## Crear y Usar Variables de Entorno { #create-and-use-env-vars }
    
    Puedes **crear** y usar variables de entorno en la **shell (terminal)**, sin necesidad de Python:
    
    //// tab | Linux, macOS, Windows Bash
    
    <div class="termy">
    
    ```console
    // Podrías crear una env var MY_NAME con
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 8.3K bytes
    - Click Count (0)
  8. internal/event/errors.go

    }
    
    // ErrDuplicateQueueConfiguration - duplicate queue configuration error.
    type ErrDuplicateQueueConfiguration struct {
    	Queue Queue
    }
    
    func (err ErrDuplicateQueueConfiguration) Error() string {
    	var message string
    	if data, xerr := xml.Marshal(err.Queue); xerr != nil {
    		message = fmt.Sprintf("%+v", err.Queue)
    	} else {
    		message = string(data)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 4.1K bytes
    - Click Count (0)
  9. docs/es/docs/index.md

        * ...y más.
    
    ### Despliega tu app (opcional) { #deploy-your-app-optional }
    
    Opcionalmente puedes desplegar tu app de FastAPI en [FastAPI Cloud](https://fastapicloud.com), ve y únete a la lista de espera si no lo has hecho. 🚀
    
    Si ya tienes una cuenta de **FastAPI Cloud** (te invitamos desde la lista de espera 😉), puedes desplegar tu aplicación con un solo comando.
    
    <div class="termy">
    
    ```console
    $ fastapi deploy
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 22.6K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/helper/LogNotificationHelper.java

            } catch (final Exception e) {
                maxBufferSize = 1000;
            }
            queue.offer(event);
            if (size.incrementAndGet() > maxBufferSize) {
                if (queue.poll() != null) {
                    size.decrementAndGet();
                }
            }
        }
    
        /**
         * Drains all events from the buffer and returns them as a list.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 5.3K bytes
    - Click Count (0)
Back to Top