Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for tryLock (0.25 sec)

  1. subprojects/composite-builds/src/test/groovy/org/gradle/composite/internal/DefaultIncludedBuildTaskGraphParallelTest.groovy

            _ * project.services >> projectServices
            _ * project.pluginManager >> Stub(PluginManagerInternal)
            def lock = Stub(ResourceLock)
            _ * projectState.taskExecutionLock >> lock
            _ * lock.tryLock() >> true
            return task
        }
    
        private BuildWorkGraphController buildWorkGraphController(String displayName, BuildServices services) {
            def builder = Mock(BuildLifecycleController.WorkGraphBuilder)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 05 16:29:26 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/execution/ResidualProgramCompiler.kt

            }
        }
    
        private
        fun MethodVisitor.compiledScriptClassInstantiation(compiledScriptClass: InternalName, instantiation: MethodVisitor.() -> Unit) {
    
            TRY_CATCH<Throwable>(
                tryBlock = {
    
                    instantiation()
                },
                catchBlock = {
    
                    emitOnScriptException(compiledScriptClass)
                }
            )
        }
    
        private
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 01 13:09:45 UTC 2024
    - 27.1K bytes
    - Viewed (0)
Back to top