Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 558 for nThreads (0.19 sec)

  1. src/cmd/cgo/internal/test/cthread_unix.c

    	max = *(int*)p;
    	for(i=0; i<max; i++)
    		Add(i);
    	return 0;
    }
    
    void
    doAdd(int max, int nthread)
    {
    	enum { MaxThread = 20 };
    	int i;
    	pthread_t thread_id[MaxThread];
    	
    	if(nthread > MaxThread)
    		nthread = MaxThread;
    	for(i=0; i<nthread; i++)
    		pthread_create(&thread_id[i], 0, addThread, &max);
    	for(i=0; i<nthread; i++)
    		pthread_join(thread_id[i], 0);		
    }
    
    static void*
    goDummyCallbackThread(void* p)
    {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 17 21:53:11 UTC 2023
    - 1K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/TestLocking.java

                } else {
                    t.url = args[ai];
                }
            }
    
            Thread[] threads = new Thread[t.numThreads];
            int ti;
    
            for (ti = 0; ti < t.numThreads; ti++) {
                threads[ti] = new Thread(t);
                System.out.print(threads[ti].getName());
                threads[ti].start();
            }
    
            while (t.numComplete < t.numThreads) {
                long delay;
    
    Registered: Wed Jun 12 15:45:55 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 3.4K bytes
    - Viewed (0)
  3. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/ExclusiveCacheAccessCoordinator.java

         *
         * <p>This method is re-entrant, so that an action can call back into this method.</p>
         *
         * <p>Note: this method differs from {@link #withFileLock(Supplier)} in that this method also blocks other threads from this process and all threads from other processes from accessing the cache.</p>
         */
        <T> T useCache(Supplier<? extends T> action);
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:50 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

        this.nameFormat = nameFormat;
        return this;
      }
    
      /**
       * Sets daemon or not for new threads created with this ThreadFactory.
       *
       * @param daemon whether or not new Threads created with this ThreadFactory will be daemon threads
       * @return this for the builder pattern
       */
      @CanIgnoreReturnValue
      public ThreadFactoryBuilder setDaemon(boolean daemon) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 10 21:56:03 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  5. pkg/ctrlz/topics/assets/templates/proc.html

    </p>
    
    <table>
        <thead>
        <tr>
            <th>Name</th>
            <th>Value</th>
        </tr>
        </thead>
    
        <tbody>
            <tr>
                <td># Threads</td>
                <td id="Threads">{{.Threads}}</td>
            </tr>
    
            <tr>
                <td># Goroutines</td>
                <td id="Goroutines">{{.Goroutines}}</td>
            </tr>
    
            <tr>
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

        this.nameFormat = nameFormat;
        return this;
      }
    
      /**
       * Sets daemon or not for new threads created with this ThreadFactory.
       *
       * @param daemon whether or not new Threads created with this ThreadFactory will be daemon threads
       * @return this for the builder pattern
       */
      @CanIgnoreReturnValue
      public ThreadFactoryBuilder setDaemon(boolean daemon) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 10 21:56:03 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  7. platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/ExecutorFactory.java

         * @param corePoolSize The number of threads to keep in the pool
         * @param maximumPoolSize The maximum number of threads allowed
         * @param keepAliveTime  when the number of threads is greater than
         *        the core, this is the maximum time that excess idle threads
         *        will wait for new tasks before terminating.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 19:07:35 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  8. subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java

     *
     * <p>Provides several ways to start and manage threads. You can use the {@link #start(groovy.lang.Closure)} or {@link
     * #run(groovy.lang.Closure)} methods to execute test code in other threads. You can use {@link #waitForAll()} to wait
     * for all test threads to complete. In addition, the test tear-down method blocks until all test threads have stopped
     * and ensures that no exceptions were thrown in any test threads.</p>
     *
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Oct 05 19:36:14 UTC 2023
    - 23.3K bytes
    - Viewed (0)
  9. platforms/ide/tooling-api/src/integTest/groovy/org/gradle/integtests/tooling/ConcurrentToolingApiIntegrationSpec.groovy

        final ToolingApi toolingApi = new ToolingApi(dist, temporaryFolder)
    
        int threads = 3
    
        def setup() {
            concurrent.shortTimeout = 180000
            settingsFile.touch()
        }
    
        def "handles the same target gradle version concurrently"() {
            buildFile << "apply plugin: 'java'"
    
            when:
            threads.times {
                concurrent.start { useToolingApi(toolingApi) }
            }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:20 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/cpumanager/topology/topology.go

    }
    
    // getUniqueCoreID computes coreId as the lowest cpuID
    // for a given Threads []int slice. This will assure that coreID's are
    // platform unique (opposite to what cAdvisor reports)
    func getUniqueCoreID(threads []int) (coreID int, err error) {
    	if len(threads) == 0 {
    		return 0, fmt.Errorf("no cpus provided")
    	}
    
    	if len(threads) != cpuset.New(threads...).Size() {
    		return 0, fmt.Errorf("cpus provided are not unique")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 7.9K bytes
    - Viewed (0)
Back to top