- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 502 for timerC (0.18 sec)
-
src/runtime/lock_sema.go
if gp.m.locks < 0 { throw("runtime·lock: lock count") } gp.m.locks++ // Speculative grab for lock. if atomic.Casuintptr(&l.key, 0, locked) { return } semacreate(gp.m) timer := &lockTimer{lock: l} timer.begin() // On uniprocessor's, no point spinning. // On multiprocessors, spin for ACTIVE_SPIN attempts. spin := 0 if ncpu > 1 { spin = active_spin } Loop: for i := 0; ; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutTarget.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, * either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.core.timer; /** * タイムアウトを処理するインターフェースです。 * * @author higa * */ @FunctionalInterface public interface TimeoutTarget { /** * タイムアウトの処理を記述します。 */ void expired();
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 904 bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java
@Override public void measure(Runnable runnable) { if (isEnabled()) { Timer timer = Time.startTimer(); runnable.run(); total.addAndGet(timer.getElapsedMillis()); } else { runnable.run(); } } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 04:43:28 UTC 2024 - 20.9K bytes - Viewed (0) -
pkg/kube/controllers/queue.go
// WaitForClose an error if the timeout expires. func (q Queue) WaitForClose(timeout time.Duration) error { closed := q.Closed() if timeout == 0 { <-closed return nil } timer := time.NewTimer(timeout) defer timer.Stop() select { case <-closed: return nil case <-timer.C: return fmt.Errorf("timeout waiting for queue to close after %v", timeout) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.3K bytes - Viewed (0) -
platforms/jvm/language-java/src/main/java/org/gradle/api/internal/tasks/compile/incremental/SelectiveCompiler.java
import org.gradle.api.internal.tasks.compile.incremental.transaction.CompileTransaction; import org.gradle.api.tasks.WorkResult; import org.gradle.internal.time.Time; import org.gradle.internal.time.Timer; import org.gradle.language.base.internal.compile.Compiler; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.File; import java.util.Collection; import java.util.Objects;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 5.8K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen.go
Krishnan Parthasarathi <******@****.***> 1711041695 -0700
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 9.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/ExclusiveCacheAccessingWorker.java
import org.gradle.internal.UncheckedException; import org.gradle.internal.concurrent.ExecutorPolicy; import org.gradle.internal.concurrent.Stoppable; import org.gradle.internal.time.CountdownTimer; import org.gradle.internal.time.Time; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.CountDownLatch;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 8.8K bytes - Viewed (0) -
cmd/tier-last-day-stats.go
} // forwardTo moves time to t, clearing entries between last update and t. func (l *lastDayTierStats) forwardTo(t time.Time) { if t.IsZero() { t = time.Now() } since := t.Sub(l.UpdatedAt).Hours() // within the hour since l.UpdatedAt if since < 1 { return } idx, lastIdx := t.Hour(), l.UpdatedAt.Hour() l.UpdatedAt = t // update to the latest time index if since >= 24 { l.Bins = [24]tierStats{}
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 2.8K bytes - Viewed (0) -
pkg/kubelet/config/file_linux_test.go
t.Fatalf("%s: Expected: %#v, Got: %#v", testCase.desc, testCase.expected, update) } return case <-timer: t.Fatalf("%s: Expected update, timeout instead", testCase.desc) } } } func expectEmptyUpdate(t *testing.T, ch chan interface{}) { timer := time.After(5 * time.Second) for { select { case got := <-ch: update := got.(kubetypes.PodUpdate) if len(update.Pods) != 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 14 09:38:23 UTC 2022 - 12.3K bytes - Viewed (0) -
src/syscall/exec_unix_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 22 04:41:27 UTC 2024 - 7.9K bytes - Viewed (0)