Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 361 for walkers (0.07 seconds)

  1. docs/es/docs/deployment/concepts.md

    Pero en muchos casos, querrás ejecutar varios worker processes al mismo tiempo.
    
    ### Múltiples Procesos - Workers { #multiple-processes-workers }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 20K bytes
    - Click Count (0)
  2. .ci/jobs.t/elastic+elasticsearch+multijob+platform-support-windows.yml

              del /f /s /q %USERPROFILE%\.gradle\init.d\*.*
              mkdir %USERPROFILE%\.gradle\init.d
              copy .ci\init.gradle %USERPROFILE%\.gradle\init.d\
              (
                echo call %GRADLEW_BAT% --max-workers=4 -Dbwc.checkout.align=true %GRADLE_TASK% ^|^| exit /b 1
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Jun 09 01:50:21 GMT 2021
    - 1.7K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

           *
           * Fortunately, exceptions rarely contain references to expensive resources.
           */
    
          //
          seenExceptionsLocal = newConcurrentHashSet();
          /*
           * Other handleException() callers may see this as soon as we publish it. We need to populate
           * it with the initial failure before we do, or else they may think that the initial failure
           * has never been seen before.
           */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  4. internal/s3select/csv/reader.go

    	recordsRead  int                    // number of records read in current slice
    	input        chan *queueItem        // input for workers
    	queue        chan *queueItem        // output from workers in order
    	err          error                  // global error state, only touched by Reader.Read
    	bufferPool   bpool.Pool[[]byte]     // pool of []byte objects for input
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

      // TODO: Test blocking to re-enter monitor after being signaled.
      // TODO: Test interrupts with both interruptible and uninterruptible monitor.
      // TODO: Test multiple waiters: If guard is still satisfied, signal next waiter.
      // TODO: Test multiple waiters: If guard is no longer satisfied, do not signal next waiter.
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  6. cmd/erasure-server-pool-rebalance.go

    	if err != nil {
    		rebalanceLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    		workerSize = len(pool.sets)
    	}
    
    	// Each decom worker needs one List() goroutine/worker
    	// add that many extra workers.
    	workerSize += len(pool.sets)
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		return err
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

      // TODO: Test blocking to re-enter monitor after being signaled.
      // TODO: Test interrupts with both interruptible and uninterruptible monitor.
      // TODO: Test multiple waiters: If guard is still satisfied, signal next waiter.
      // TODO: Test multiple waiters: If guard is no longer satisfied, do not signal next waiter.
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.2K bytes
    - Click Count (0)
  8. cmd/batch-expire_test.go

          purge:
              # retainVersions: 0 # (default) delete all versions of the object. This option is the fastest.
              # retainVersions: 5 # keep the latest 5 versions of the object including delete markers.
    
      notify:
        endpoint: https://notify.endpoint # notification endpoint to receive job completion status
        token: Bearer xxxxx # optional authentication token for the notification endpoint
      
      retry:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 01 12:53:30 GMT 2024
    - 5.5K bytes
    - Click Count (0)
  9. build-logic/buildquality/src/main/kotlin/gradlebuild/incubation/action/IncubatingApiReportAggregationParameter.kt

     */
    
    package gradlebuild.incubation.action
    
    import org.gradle.api.file.ConfigurableFileCollection
    import org.gradle.api.file.RegularFileProperty
    import org.gradle.api.provider.Property
    import org.gradle.workers.WorkParameters
    
    
    interface IncubatingApiReportAggregationParameter : WorkParameters {
        val reports: ConfigurableFileCollection
        val htmlReportFile: RegularFileProperty
        val csvReportFile: RegularFileProperty
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu May 29 08:21:16 GMT 2025
    - 1.1K bytes
    - Click Count (0)
  10. build-conventions/src/main/java/org/elasticsearch/gradle/internal/conventions/precommit/PrecommitTask.java

    import java.nio.file.StandardOpenOption;
    
    public class PrecommitTask extends DefaultTask {
    
        @OutputFile
        public File getSuccessMarker() {
            return new File(getProjectLayout().getBuildDirectory().getAsFile().get(), "markers/" + this.getName());
        }
    
        @TaskAction
        public void writeMarker() throws IOException {
            Files.write(getSuccessMarker().toPath(), new byte[] {}, StandardOpenOption.CREATE);
        }
    
        @Inject
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 1.2K bytes
    - Click Count (0)
Back to Top