Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 228 for Blocker (0.3 seconds)

  1. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 10K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java

      private OverflowAvoidingLockSupport() {}
    
      static void parkNanos(@Nullable Object blocker, long nanos) {
        // Even in the extremely unlikely event that a thread unblocks itself early after only 68 years,
        // this is indistinguishable from a spurious wakeup, which LockSupport allows.
        LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD));
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 1.6K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        // after some period of time the runner thread should become blocked on the task because it is
        // waiting for the slow interrupting thread to complete Thread.interrupt
        awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);
    
        Blocker blocker = (Blocker) LockSupport.getBlocker(runner);
        Thread owner = blocker.getOwner();
        assertThat(owner).isSameInstanceAs(interrupter);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        // after some period of time the runner thread should become blocked on the task because it is
        // waiting for the slow interrupting thread to complete Thread.interrupt
        awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);
    
        Blocker blocker = (Blocker) LockSupport.getBlocker(runner);
        Thread owner = blocker.getOwner();
        assertThat(owner).isSameInstanceAs(interrupter);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  5. internal/lsync/lrwmutex_test.go

    	wl := NewLRWMutex()
    	var rl sync.Locker
    	wlocked := make(chan bool, 1)
    	rlocked := make(chan bool, 1)
    	rl = wl.DRLocker()
    	n := 10
    	go func() {
    		for range n {
    			rl.Lock()
    			rl.Lock()
    			rlocked <- true
    			wl.Lock()
    			wlocked <- true
    		}
    	}()
    	for range n {
    		<-rlocked
    		rl.Unlock()
    		select {
    		case <-wlocked:
    			t.Fatal("RLocker() didn't read-lock it")
    		default:
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  6. docs/fr/docs/deployment/docker.md

    Vous pouvez en lire davantage dans la [documentation Docker sur les formes shell et exec](https://docs.docker.com/reference/dockerfile/#shell-and-exec-form).
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 32.3K bytes
    - Click Count (0)
  7. docs/pt/docs/deployment/docker.md

    Você pode ler mais na [documentação do Docker sobre as formas shell e exec](https://docs.docker.com/reference/dockerfile/#shell-and-exec-form).
    
    Isso pode ser bem perceptível ao usar `docker compose`. Veja esta seção de FAQ do Docker Compose para mais detalhes técnicos: [Por que meus serviços demoram 10 segundos para recriar ou parar?](https://docs.docker.com/compose/faq/#why-do-my-services-take-10-seconds-to-recreate-or-stop).
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:20:43 GMT 2026
    - 30.9K bytes
    - Click Count (0)
  8. cmd/namespace-lock.go

    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/lsync"
    )
    
    // local lock servers
    var globalLockServer *localLocker
    
    // RWLocker - locker interface to introduce GetRLock, RUnlock.
    type RWLocker interface {
    	GetLock(ctx context.Context, timeout *dynamicTimeout) (lkCtx LockContext, timedOutErr error)
    	Unlock(lkCtx LockContext)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  9. docs/ja/docs/deployment/docker.md

    コンテナ(Docker)イメージを手に入れた後、それをデプロイするにはいくつかの方法があります。
    
    例えば以下のリストの方法です:
    
    * 単一サーバーの**Docker Compose**
    * **Kubernetes**クラスタ
    * Docker Swarmモードのクラスター
    * Nomadのような別のツール
    * コンテナ・イメージをデプロイするクラウド・サービス
    
    ## `uv` を使ったDockerイメージ { #docker-image-with-uv }
    
    [uv](https://github.com/astral-sh/uv) を使ってプロジェクトのインストールと管理をしている場合は、[uv Docker guide](https://docs.astral.sh/uv/guides/integration/docker/)に従ってください。
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 14:07:17 GMT 2026
    - 36.8K bytes
    - Click Count (0)
  10. docs/ru/docs/deployment/docker.md

    Подробнее об этом читайте в [документации Docker о shell- и exec-формах](https://docs.docker.com/reference/dockerfile/#shell-and-exec-form).
    
    Это особенно заметно при использовании `docker compose`. См. раздел FAQ Docker Compose с техническими подробностями: [Почему мои сервисы пересоздаются или останавливаются 10 секунд?](https://docs.docker.com/compose/faq/#why-do-my-services-take-10-seconds-to-recreate-or-stop).
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 17:56:20 GMT 2026
    - 43.5K bytes
    - Click Count (0)
Back to Top