Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 339 for queues (0.06 seconds)

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

  1. docs/es/docs/advanced/openapi-callbacks.md

    En este caso, podrías querer documentar cómo esa API externa *debería* verse. Qué *path operation* debería tener, qué cuerpo debería esperar, qué response debería devolver, etc.
    
    ## Una aplicación con callbacks { #an-app-with-callbacks }
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Dec 16 16:33:45 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter1.start();
        waiter1.awaitWaiting();
    
        WaiterThread waiter2 = new WaiterThread(future);
        waiter2.start();
        waiter2.awaitWaiting();
        // The waiter queue should be waiter2->waiter1
    
        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  3. internal/event/target/elasticsearch.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of Elasticsearch `%s`: %w", id, err)
    		}
    	}
    
    	target := &ElasticsearchTarget{
    		id:         event.TargetID{ID: id, Name: "elasticsearch"},
    		args:       args,
    		store:      queueStore,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter1.start();
        waiter1.awaitWaiting();
    
        WaiterThread waiter2 = new WaiterThread(future);
        waiter2.start();
        waiter2.awaitWaiting();
        // The waiter queue should be waiter2->waiter1
    
        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  5. docs/pt/docs/deployment/docker.md

    ### Contêineres com Múltiplos Processos e Casos Especiais { #containers-with-multiple-processes-and-special-cases }
    
    Claro, existem **casos especiais** em que você pode querer ter **um contêiner** com vários **processos workers do Uvicorn** dentro.
    
    Nesses casos, você pode usar a opção de linha de comando `--workers` para definir o número de workers que deseja executar:
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Nov 12 16:23:57 GMT 2025
    - 32.1K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java

                urlFilterService.delete(sid);
            } catch (final Exception e) {
                logger.warn("Failed to delete UrlFilter: sessionId={}", sid, e);
            }
    
            try {
                // clear queue
                urlQueueService.clearCache();
                urlQueueService.delete(sid);
            } catch (final Exception e) {
                logger.warn("Failed to delete UrlQueue: sessionId={}", sid, e);
            }
    
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 25K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/util/GsaConfigParser.java

        /** Array of supported file protocols for URL classification. */
        protected String[] fileProtocols = { "file:", "smb:", "smb1:", "ftp:", "storage:" };
    
        /** Queue to track the current XML element hierarchy during parsing. */
        protected LinkedList<String> tagQueue;
    
        /** List to store parsed label types for access control. */
        protected List<LabelType> labelList;
    
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 21.6K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

        threadPool.shutdown();
        threadPool.awaitTermination(300, SECONDS);
    
        // Since we're not doing any more cache operations, and the cache only expires/evicts when doing
        // other operations, the cache and the removal queue won't change from this point on.
    
        // Verify that each received removal notification was valid
        for (RemovalNotification<String, String> notification : removalListener) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 30 22:03:28 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  9. cmd/bucket-replication-utils.go

    			sz += t.Size
    		}
    	}
    	return sz
    }
    
    // ReplicationAttempted returns true if replication was attempted on any of the targets for the object version
    // queued
    func (ri replicatedInfos) ReplicationResynced() bool {
    	for _, t := range ri.Targets {
    		if t.Empty() || !t.ReplicationResynced {
    			continue
    		}
    		return true
    	}
    	return false
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  10. docs/pt/docs/advanced/security/oauth2-scopes.md

    Porém em sua aplicação, por segurança, você deve garantir que você apenas adiciona os escopos que o usuário possui permissão de fato, ou aqueles que você predefiniu.
    
    ///
    
    {* ../../docs_src/security/tutorial005_an_py310.py hl[157] *}
    
    ## Declare escopos em *operações de rota* e dependências { #declare-scopes-in-path-operations-and-dependencies }
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Nov 12 16:23:57 GMT 2025
    - 14.9K bytes
    - Click Count (0)
Back to Top