Search Options

Results per page
Sort
Preferred Languages
Advance

Results 951 - 960 of 977 for concurrent (0.12 sec)

  1. android/guava/src/com/google/common/collect/Tables.java

       * longer, since an iteration across all row keys occurs.
       *
       * <p>Note that this implementation is not synchronized. If multiple threads access this table
       * concurrently and one of the threads modifies the table, it must be synchronized externally.
       *
       * <p>The table is serializable if {@code backingMap}, {@code factory}, the maps generated by
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  2. cmd/erasure-metadata.go

    	return writeAllMetadataWithRevert(ctx, disks, origbucket, bucket, prefix, files, quorum, true)
    }
    
    // writeUniqueFileInfo - writes unique `xl.meta` content for each disk concurrently.
    func writeUniqueFileInfo(ctx context.Context, disks []StorageAPI, origbucket, bucket, prefix string, files []FileInfo, quorum int) ([]StorageAPI, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  3. common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto

      // Populated by the system.
      // Read-only.
      // More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#concurrency-control-and-consistency
      // +optional
      optional string resourceVersion = 2;
    
      // continue may be set if the user set a limit on the number of items returned, and indicates that
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  4. cmd/batch-handlers.go

    				stopFn := globalBatchJobsMetrics.trace(batchJobMetricReplication, job.ID, attempts)
    				success := true
    				if err := r.ReplicateFromSource(ctx, api, core, oi, retry); err != nil {
    					// object must be deleted concurrently, allow these failures but do not count them
    					if isErrVersionNotFound(err) || isErrObjectNotFound(err) {
    						return
    					}
    					stopFn(oi, err)
    					batchLogIf(ctx, err)
    					success = false
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    		// Initiate ticker after body has been read.
    		ticker := time.NewTicker(time.Second * 10)
    		defer ticker.Stop()
    
    		for {
    			select {
    			case <-ticker.C:
    				// The done() might have been called
    				// concurrently, check for it before we
    				// write the filler byte.
    				select {
    				case err := <-doneCh:
    					if err != nil {
    						write([]byte{1})
    						write([]byte(err.Error()))
    					} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  6. docs/pt/docs/async.md

    ### Conclusão dos hambúrgueres
    
    Nesse cenário dos "hambúrgueres com seu _crush_ :heart_eyes:", como tem muita espera, faz mais sentido ter um sistema concorrente.
    
    Esse é o caso da maioria das aplicações web.
    
    Geralmente são muitos usuários, e seu servidor está esperando pelas suas conexões não tão boas para enviar as requisições.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  7. docs/en/docs/deployment/concepts.md

    * Others...
    
    ## Replication - Processes and Memory
    
    With a FastAPI application, using a server program like the `fastapi` command that runs Uvicorn, running it once in **one process** can serve multiple clients concurrently.
    
    But in many cases, you will want to run several worker processes at the same time.
    
    ### Multiple Processes - Workers
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Sep 18 16:09:57 UTC 2024
    - 17.8K bytes
    - Viewed (0)
  8. RELEASE.md

            classification.
    
    *   `tf.data`:
    
        *   Added support for cross-trainer data caching in tf.data service. This
            saves computation resources when concurrent training jobs train from the
            same dataset. See
            (https://www.tensorflow.org/api_docs/python/tf/data/experimental/service#sharing_tfdata_service_with_concurrent_trainers)
            for more details.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Oct 22 14:33:53 UTC 2024
    - 735.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/FluentIterable.java

      public final Optional<@NonNull E> last() {
        // Iterables#getLast was inlined here so we don't have to throw/catch a NSEE
    
        // TODO(kevinb): Support a concurrently modified collection?
        Iterable<E> iterable = getDelegate();
        if (iterable instanceof List) {
          List<E> list = (List<E>) iterable;
          if (list.isEmpty()) {
            return Optional.absent();
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Sep 24 13:42:31 UTC 2024
    - 35.7K bytes
    - Viewed (0)
  10. cmd/peer-rest-client.go

    	values := make(url.Values)
    	values.Set(peerRESTSize, strconv.Itoa(opts.objectSize))
    	values.Set(peerRESTConcurrent, strconv.Itoa(opts.concurrency))
    	values.Set(peerRESTDuration, opts.duration.String())
    	values.Set(peerRESTStorageClass, opts.storageClass)
    	values.Set(peerRESTBucket, opts.bucketName)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
Back to top