Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 337 for enqueue (0.16 sec)

  1. docs/en/data/external_links.yml

    I'm Leaving Flask - author: Mike Moritz author_link: https://medium.com/@mike.p.moritz link: https://medium.com/@mike.p.moritz/using-docker-compose-to-deploy-a-lightweight-python-rest-api-with-a-job-queue-37e6072a209b title: Using Docker Compose to deploy a lightweight Python REST API with a job queue - author: '@euri10' author_link: https://gitlab.com/euri10 link: https://gitlab.com/euri10/fastapi_cheatsheet title: A FastAPI and Swagger UI visual cheatsheet - author: Uber Engineering author_link:...
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Oct 24 18:39:34 UTC 2024
    - 22.8K bytes
    - Viewed (0)
  2. CHANGELOG/CHANGELOG-1.32.md

    - Fixes the bug in PodTopologySpread that only happens with QHint enabled, 
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 29 20:17:52 UTC 2024
    - 121.6K bytes
    - Viewed (0)
  3. internal/event/target/nats.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 NATS `%s`: %w", id, err)
    		}
    	}
    
    	target := &NATSTarget{
    		id:         event.TargetID{ID: id, Name: "nats"},
    		args:       args,
    		loggerOnce: loggerOnce,
    		store:      queueStore,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java

                urlFilterService.delete(sid);
            } catch (final Exception e) {
                logger.warn("Failed to delete UrlFilter for {}", sid, e);
            }
    
            try {
                // clear queue
                urlQueueService.clearCache();
                urlQueueService.delete(sid);
            } catch (final Exception e) {
                logger.warn("Failed to delete UrlQueue for {}", sid, e);
            }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  5. 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,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  6. docs/config/README.md

    
    ```
    ~ mc admin config set alias/ heal
    KEY:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 17.9K bytes
    - Viewed (1)
  7. CHANGELOG.md

     *  Fix: Skip early hints (status code 103) responses.
     *  Fix: Don't log sensitive headers in `Request.toString()`.
     *  Fix: Don't crash when the dispatcher's `ExecutorService` is shutdown with many
        calls still enqueued.
     *  Upgrade: [GraalVM 22][graalvm_22].
     *  Upgrade: [Kotlin 1.7.10][kotlin_1_7_10].
    
    
    ## Version 5.0.0-alpha.10
    
    _2022-06-26_
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:31:39 UTC 2024
    - 21.4K bytes
    - Viewed (1)
  8. cni/pkg/nodeagent/ztunnelserver.go

    	so that we can remove stale entries when the ztunnel pod is deleted
    	or when the ztunnel pod is restarted in the same pod (remove old entries when the same uid connects again, but with different boot id?)
    
    	save a queue of what needs to be sent to the ztunnel pod and send it one by one when it connects.
    
    	when a new ztunnel connects with different uid, only propagate deletes to older ztunnels.
    */
    
    type connMgr struct {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

                if (!cleanup) {
                    return executorService.submit(() -> process(fessConfig, entity));
                }
                if (logger.isDebugEnabled()) {
                    logger.debug("Removing thumbnail queue: {}", entity);
                }
                return null;
            }).filter(f -> f != null).forEach(f -> {
                try {
                    f.get();
                } catch (final Exception e) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  10. 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
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
Back to top