Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 226 for yield (0.07 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

       * specified, may re-sleep or yield until time elapses.
       */
      static void delay(long millis) throws InterruptedException {
        long startTime = System.nanoTime();
        long ns = millis * 1000 * 1000;
        for (; ; ) {
          if (millis > 0L) Thread.sleep(millis);
          else // too short to sleep
          Thread.yield();
          long d = ns - (System.nanoTime() - startTime);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 19:21:11 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  2. docs/en/docs/release-notes.md

    Using resources from dependencies with `yield` in background tasks is no longer supported.
    
    This change is what supports the new features, read below. 🤓
    
    ### Dependencies with `yield`, `HTTPException` and Background Tasks
    
    Dependencies with `yield` now can raise `HTTPException` and other exceptions after `yield`. 🎉
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Fri Jun 14 15:07:37 UTC 2024
    - 395.4K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java

            newStartedThread(
                new CheckedRunnable() {
                  @Override
                  public void realRun() {
                    while (!at.compareAndSet(2.0, 3.0)) {
                      Thread.yield();
                    }
                  }
                });
    
        assertTrue(at.compareAndSet(1.0, 2.0));
        awaitTermination(t);
        assertBitEquals(3.0, at.get());
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 19:21:11 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  4. platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/problems/ConfigurationCacheReport.kt

                    hasher.putString(element.toString())
                }
            }
            return hasher.hash()
        }
    
        private
        suspend fun SequenceScope<Failure>.visitFailures(failure: Failure) {
            yield(failure)
            failure.suppressed.forEach { visitFailures(it) }
            failure.causes.forEach { visitFailures(it) }
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:30 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java

            newStartedThread(
                new CheckedRunnable() {
                  @Override
                  public void realRun() {
                    while (!a.compareAndSet(0, 2.0, 3.0)) {
                      Thread.yield();
                    }
                  }
                });
    
        assertTrue(a.compareAndSet(0, 1.0, 2.0));
        awaitTermination(t);
        assertBitEquals(3.0, a.get(0));
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 19:21:11 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  6. src/sync/mutex.go

    			if atomic.CompareAndSwapInt32(&m.state, old, new) {
    				runtime_Semrelease(&m.sema, false, 1)
    				return
    			}
    			old = m.state
    		}
    	} else {
    		// Starving mode: handoff mutex ownership to the next waiter, and yield
    		// our time slice so that the next waiter can start to run immediately.
    		// Note: mutexLocked is not set, the waiter will set it after wakeup.
    		// But mutex is still considered locked if mutexStarving is set,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. tensorflow/compiler/mlir/lite/tests/ops.mlir

        %1 = func.call @WhileOp_cond(%arg2, %arg3) : (tensor<*xi32>, tensor<*xf32>) -> tensor<i1>
        "tfl.yield"(%1) : (tensor<i1>) -> ()
      },  {
      ^bb0(%arg2: tensor<*xi32>, %arg3: tensor<*xf32>):
        %1:2 = func.call @WhileOp_body(%arg2, %arg3) : (tensor<*xi32>, tensor<*xf32>) -> (tensor<*xi32>, tensor<*xf32>)
        "tfl.yield"(%1#0, %1#1) : (tensor<*xi32>, tensor<*xf32>) -> ()
      }) : (tensor<i32>, tensor<1xf32>) -> (tensor<i32>)
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Jun 06 19:09:08 UTC 2024
    - 189.2K bytes
    - Viewed (0)
  8. doc/go_spec.html

    	left, right *Tree[K, V]
    	key         K
    	value       V
    }
    
    func (t *Tree[K, V]) walk(yield func(key K, val V) bool) bool {
    	return t == nil || t.left.walk(yield) && yield(t.key, t.value) && t.right.walk(yield)
    }
    
    func (t *Tree[K, V]) Walk(yield func(key K, val V) bool) {
    	t.walk(yield)
    }
    
    // walk tree t in-order
    var t Tree[string, int]
    for k, v := range t.Walk {
    	// process k, v
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 21:07:21 UTC 2024
    - 281.5K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

          }
        }
    
        void awaitWaiting() {
          while (!isBlocked()) {
            if (getState() == State.TERMINATED) {
              throw new RuntimeException("Thread exited");
            }
            Thread.yield();
          }
        }
    
        private boolean isBlocked() {
          return getState() == Thread.State.WAITING && LockSupport.getBlocker(this) == future;
        }
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

          }
        }
    
        void awaitWaiting() {
          while (!isBlocked()) {
            if (getState() == State.TERMINATED) {
              throw new RuntimeException("Thread exited");
            }
            Thread.yield();
          }
        }
    
        private boolean isBlocked() {
          return getState() == Thread.State.WAITING && LockSupport.getBlocker(this) == future;
        }
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
Back to top