Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 677 for threaded (0.12 sec)

  1. subprojects/core/src/integTest/groovy/org/gradle/internal/operations/logging/LoggingBuildOperationProgressIntegTest.groovy

                        tasks.all.logger.lifecycle("build finished from \${tasks.all.path}")
                    }
                }
    
                threaded {
                    println("threaded configuration output")
                }
    
                def threaded(Closure action) {
                    Thread.start(action).join()
                }
            """
    
            when:
            succeeds("all")
    
            then:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri May 17 13:27:34 UTC 2024
    - 17.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/tlsconfig.go

    	newContent, err := c.newTLSContent()
    	if err != nil {
    		return err
    	}
    	// if the content is the same as what we currently have, we can simply skip it.  This works because we are single
    	// threaded.  If you ever make this multi-threaded, add a lock.
    	if newContent.Equal(c.currentlyServedContent) {
    		return nil
    	}
    
    	// make a shallow copy and override the dynamic pieces which have changed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  3. maven-embedder/src/main/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListener.java

    import org.eclipse.aether.transfer.TransferEvent;
    import org.eclipse.aether.transfer.TransferResource;
    
    /**
     * Console download progress meter.
     * <p>
     * This listener is not thread-safe and should be wrapped in the {@link SimplexTransferListener} in a multi-threaded scenario.
     */
    public class ConsoleMavenTransferListener extends AbstractMavenTransferListener {
    
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Tue Jun 11 21:48:41 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  4. samples/bookinfo/src/productpage/productpage.py

        logging.info("start at port %s" % (p))
        # Make it compatible with IPv6 if Linux
        if sys.platform == "linux":
            app.run(host='::', port=p, debug=False, threaded=True)
        else:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 14:35:54 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ExecutionList.java

      /** Logger to log exceptions caught when running runnables. */
      private static final LazyLogger log = new LazyLogger(ExecutionList.class);
    
      /**
       * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link
       * RunnableExecutorPair#next} field.
       */
      @GuardedBy("this")
      @CheckForNull
      private RunnableExecutorPair runnables;
    
      @GuardedBy("this")
      private boolean executed;
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 22 21:17:24 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

      /** Logger to log exceptions caught when running runnables. */
      private static final LazyLogger log = new LazyLogger(ExecutionList.class);
    
      /**
       * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link
       * RunnableExecutorPair#next} field.
       */
      @GuardedBy("this")
      @CheckForNull
      private RunnableExecutorPair runnables;
    
      @GuardedBy("this")
      private boolean executed;
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 22 21:17:24 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  7. src/syscall/exec_unix.go

    // accidentally inherits the write end of a pipe, then the reader
    // of that pipe will not see EOF until that child exits, potentially
    // causing the parent program to hang. This is a common problem
    // in threaded C programs that use popen.
    //
    // Luckily, the file descriptors that are most important not to
    // inherit are not the ones that can take an arbitrarily long time
    // to create: pipe returns instantly, and the net package uses
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 21:03:59 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  8. subprojects/core/src/main/java/org/gradle/execution/taskgraph/DefaultTaskExecutionGraph.java

             */
            return executionPlan.getContents().getFilteredTasks();
        }
    
        private void fireWhenReady() {
            // We know that we're running single-threaded here, so we can use coarse grained project locks
            gradleInternal.getOwner().getProjects().withMutableStateOfAllProjects(
                () -> buildOperationRunner.run(
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Mar 08 13:46:07 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  9. pkg/registry/core/service/ipallocator/cidrallocator.go

    	if !cache.WaitForCacheSync(c.internalStopCh, c.serviceCIDRSynced, c.ipAddressSynced) {
    		runtime.HandleError(fmt.Errorf("timed out waiting for caches to sync"))
    		return
    	}
    
    	// this is single threaded only one serviceCIDR at a time
    	go wait.Until(c.runWorker, time.Second, c.internalStopCh)
    
    	<-c.internalStopCh
    }
    
    func (c *MetaAllocator) runWorker() {
    	for c.processNextItem() {
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  10. doc/go_mem.html

    *p += i
    </pre>
    
    <p>
    If <code>i</code> and <code>*p</code> start equal to 2,
    the original code does <code>*p = 3</code>,
    so a racing thread can read only 2 or 3 from <code>*p</code>.
    The rewritten code does <code>*p = 1</code> and then <code>*p = 3</code>,
    allowing a racing thread to read 1 as well.
    </p>
    
    <p>
    Note that all these optimizations are permitted in C/C++ compilers:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
Back to top