Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for tryLock (0.1 sec)

  1. src/sync/rwmutex.go

    	}
    }
    
    // TryLock tries to lock rw for writing and reports whether it succeeded.
    //
    // Note that while correct uses of TryLock do exist, they are rare,
    // and use of TryLock is often a sign of a deeper problem
    // in a particular use of mutexes.
    func (rw *RWMutex) TryLock() bool {
    	if race.Enabled {
    		_ = rw.w.state
    		race.Disable()
    	}
    	if !rw.w.TryLock() {
    		if race.Enabled {
    			race.Enable()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  2. src/sync/mutex.go

    	}
    	// Slow path (outlined so that the fast path can be inlined)
    	m.lockSlow()
    }
    
    // TryLock tries to lock m and reports whether it succeeded.
    //
    // Note that while correct uses of TryLock do exist, they are rare,
    // and use of TryLock is often a sign of a deeper problem
    // in a particular use of mutexes.
    func (m *Mutex) TryLock() bool {
    	old := m.state
    	if old&(mutexLocked|mutexStarving) != 0 {
    		return false
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  3. internal/grid/muxclient.go

    		gridLogIf(m.ctx, err)
    		m.closeLocked()
    		return false
    	}
    }
    
    func (m *muxClient) close() {
    	if debugPrint {
    		fmt.Println("closing outgoing mux", m.MuxID)
    	}
    	if !m.respMu.TryLock() {
    		// Cancel before locking - will unblock any pending sends.
    		if m.cancelFn != nil {
    			m.cancelFn(context.Canceled)
    		}
    		// Wait for senders to release.
    		m.respMu.Lock()
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        assertTrue(signaledBeforeTimeout);
        assertTimeNotPassed(stopwatch, LONG_DELAY_MS);
        assertInterrupted();
      }
    
      // Lock.tryLock() tests
      public void testTryLockTimeoutExceeded() {
        Stopwatch stopwatch = Stopwatch.createStarted();
        Lock lock = new ReentrantLock();
        Thread lockThread = acquireFor(lock, 5, SECONDS);
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 16:06:39 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  5. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirExpressionInfoProvider.kt

                // Body and catch blocks of try-catch expressions are used if the try-catch itself
                // is used.
                is KtTryExpression ->
                    (parent.tryBlock == child || child in parent.catchClauses) && isUsed(parent)
    
                // If expressions always use their condition, and the branches are used if the
                // If itself is used as an expression.
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Wed Jun 05 16:16:39 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  6. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirExpressionTypeProvider.kt

            val tryExpression = expression.unwrapQualified<KtTryExpression> { tryExpression, currentExpression ->
                currentExpression == tryExpression.tryBlock
            } ?: return null
            return getExpectedType(tryExpression)
        }
    
        private fun getExpectedTypeOfElvisOperand(expression: PsiElement): KaType? {
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Tue Jun 11 15:45:42 UTC 2024
    - 24.4K bytes
    - Viewed (0)
Back to top