Search Options

Results per page
Sort
Preferred Languages
Advance

Results 581 - 590 of 754 for simples (0.05 sec)

  1. src/bufio/bufio.go

    // it returns the data read before the error and the error itself (often io.EOF).
    // ReadBytes returns err != nil if and only if the returned data does not end in
    // delim.
    // For simple uses, a Scanner may be more convenient.
    func (b *Reader) ReadBytes(delim byte) ([]byte, error) {
    	full, frag, n, err := b.collectFragments(delim)
    	// Allocate new buffer to hold the full pieces and the fragment.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  2. docs/es/docs/async.md

    Pero también puedes aprovechar los beneficios del paralelismo y el multiprocesamiento (tener múltiples procesos ejecutándose en paralelo) para cargas de trabajo **CPU bound** como las de los sistemas de Machine Learning.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Aug 19 18:15:21 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractService.java

              }
            });
      }
    
      /**
       * An immutable snapshot of the current state of the service. This class represents a consistent
       * snapshot of the state and therefore it can be used to answer simple queries without needing to
       * grab a lock.
       */
      // @Immutable except that Throwable is mutable (initCause(), setStackTrace(), mutable subclasses).
      private static final class StateSnapshot {
        /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  4. internal/grid/muxclient.go

    		return nil, err
    	}
    	if debugPrint {
    		fmt.Println("Connecting Mux", m.MuxID, ",to", m.parent.Remote)
    	}
    
    	// Space for one message and an error.
    	responseCh := make(chan Response, 1)
    
    	// Spawn simple disconnect
    	if requests == nil {
    		go m.handleOneWayStream(responseCh, responses)
    		return &Stream{responses: responseCh, Requests: nil, ctx: m.ctx, cancel: m.cancelFn, muxID: m.MuxID}, nil
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  5. cmd/bucket-replication-metrics.go

    	// Bytes of unreplicated entries that were dropped after MRF retry limit reached since cluster start.
    	TotalDroppedBytes uint64 `json:"droppedBytes_since_uptime"`
    }
    
    // SMA struct for calculating simple moving average
    type SMA struct {
    	buf       []float64
    	window    int     // len of buf
    	idx       int     // current index in buf
    	CAvg      float64 // cumulative average
    	prevSMA   float64
    	filledBuf bool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  6. internal/config/identity/ldap/ldap.go

    }
    
    // GetValidatedDNUnderBaseDN checks if the given DN exists in the LDAP
    // directory.
    //
    // The `NormDN` value returned here in the search result may not be equal to the
    // input DN, as LDAP equality is not a simple Golang string equality. However,
    // we assume the value returned by the LDAP server is canonical. Additionally,
    // the attribute type names in the DN are lower-cased.
    //
    // Return values:
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 01:04:53 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  7. internal/s3select/sql/funceval.go

    	case sqlFnDateAdd:
    		return handleDateAdd(r, e.DateAdd, tableAlias)
    
    	case sqlFnDateDiff:
    		return handleDateDiff(r, e.DateDiff, tableAlias)
    
    	}
    
    	// For all simple argument functions, we evaluate the arguments here
    	argVals := make([]*Value, len(e.SFunc.ArgsList))
    	for i, arg := range e.SFunc.ArgsList {
    		argVals[i], err = arg.evalNode(r, tableAlias)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 13.2K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/ztunnelserver.go

    		go func() {
    			log.Debug("handling conn")
    			if err := z.handleConn(ctx, conn); err != nil {
    				log.Errorf("failed to handle conn: %v", err)
    			}
    		}()
    	}
    }
    
    // ZDS protocol is very simple, for every message sent, and ack is sent.
    // the ack only has temporal correlation (i.e. it is the first and only ack msg after the message was sent)
    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. docs/ru/docs/deployment/docker.md

    ![Swagger UI](https://fastapi.tiangolo.com/img/index/index-01-swagger-ui-simple.png)
    
    ## Альтернативная документация API
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Aug 12 21:47:53 UTC 2024
    - 57.6K bytes
    - Viewed (0)
  10. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

    import sun.misc.Unsafe;
    
    /** Benchmarks for {@link ExecutionList}. */
    @VmOptions({"-Xms8g", "-Xmx8g"})
    public class ExecutionListBenchmark {
      private static final int NUM_THREADS = 10; // make a param?
    
      // simple interface to wrap our two implementations.
      interface ExecutionListWrapper {
        void add(Runnable runnable, Executor executor);
    
        void execute();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 20.5K bytes
    - Viewed (0)
Back to top