Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 734 for thread1 (0.15 sec)

  1. tensorflow/c/eager/parallel_device/parallel_device_lib.h

      const std::vector<std::string> underlying_devices_;
      // A sequence of thread wrappers, one per device, for executing operations in
      // parallel.
      //
      // Conceptually this is a thread pool with one thread per device. It requires
      // less synchronization than a thread pool would for this task, since Execute
      // acquires each thread in order (and so only one Execute will schedule
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Apr 25 15:21:13 UTC 2023
    - 12.9K bytes
    - Viewed (0)
  2. src/runtime/asm_loong64.s

    	// If the m on entry was nil, we called needm above to borrow an m,
    	// 1. for the duration of the call on non-pthread platforms,
    	// 2. or the duration of the C thread alive on pthread platforms.
    	// If the m on entry wasn't nil,
    	// 1. the thread might be a Go thread,
    	// 2. or it wasn't the first call from a C thread on pthread platforms,
    	//    since then we skip dropm to resue the m in the first call.
    	MOVV	savedm-8(SP), R12
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 13 15:04:25 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  3. src/runtime/asm_mipsx.s

    	// If the m on entry was nil, we called needm above to borrow an m,
    	// 1. for the duration of the call on non-pthread platforms,
    	// 2. or the duration of the C thread alive on pthread platforms.
    	// If the m on entry wasn't nil,
    	// 1. the thread might be a Go thread,
    	// 2. or it wasn't the first call from a C thread on pthread platforms,
    	//    since then we skip dropm to reuse the m in the first call.
    	MOVW	savedm-4(SP), R3
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 06 11:46:29 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                  @Override
                  public Integer call() {
                    return Thread.currentThread().getStackTrace().length;
                  }
                },
                directExecutor());
        settableFuture.set(null);
        assertThat(getDone(stackDepthCheck))
            .isLessThan(Thread.currentThread().getStackTrace().length + 100);
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

                }
              }
            });
        awaitUninterruptibly(enteredLatch);
      }
    
      @CanIgnoreReturnValue
      static Thread startThread(Runnable runnable) {
        Thread thread = new Thread(runnable);
        thread.setDaemon(true);
        thread.start();
        return thread;
      }
    
      /**
       * Generates a test case verifying that calling any enterXxx, tryEnterXxx, or waitForXxx method
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  6. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultDaemonConnection.java

                                }
                                failure = e;
                                return;
                            }
                            if (message == null) {
                                LOGGER.debug("thread {}: Received end-of-input from client.", Thread.currentThread().getId());
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 15 19:51:37 UTC 2024
    - 16K bytes
    - Viewed (0)
  7. subprojects/composite-builds/src/main/java/org/gradle/composite/internal/DefaultIncludedBuildTaskGraph.java

            private final Thread owner;
            private final BuildControllers controllers;
            private State state = State.NotPrepared;
    
            public DefaultBuildTreeWorkGraph() {
                owner = Thread.currentThread();
                controllers = createControllers();
            }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Mar 08 10:04:24 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

            .connectionPool(ConnectionPool(connectionListener = connectionListener))
        }
    
      private fun loomThreadFactory(): ThreadFactory {
        val ofVirtual = Thread::class.java.getMethod("ofVirtual").invoke(null)
    
        return Class.forName("java.lang.Thread\$Builder")
          .getMethod("factory")
          .invoke(ofVirtual) as ThreadFactory
      }
    
      private fun isLoom(): Boolean {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  9. src/runtime/os_netbsd.go

    // Called on the parent thread (main thread in case of bootstrap), can allocate memory.
    func mpreinit(mp *m) {
    	mp.gsignal = malg(32 * 1024)
    	mp.gsignal.m = mp
    }
    
    // Called to initialize a new m (including the bootstrap m).
    // Called on the new thread, cannot allocate memory.
    func minit() {
    	gp := getg()
    	gp.m.procid = uint64(lwp_self())
    
    	// On NetBSD a thread created by pthread_create inherits the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  10. src/runtime/asm_arm.s

    	// If the m on entry was nil, we called needm above to borrow an m,
    	// 1. for the duration of the call on non-pthread platforms,
    	// 2. or the duration of the C thread alive on pthread platforms.
    	// If the m on entry wasn't nil,
    	// 1. the thread might be a Go thread,
    	// 2. or it wasn't the first call from a C thread on pthread platforms,
    	//    since then we skip dropm to reuse the m in the first call.
    	MOVW	savedm-4(SP), R6
    	CMP	$0, R6
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 23 21:00:52 UTC 2024
    - 32.1K bytes
    - Viewed (0)
Back to top