- Sort Score
- Result 10 results
- Languages All
Results 1001 - 1010 of 2,167 for latch (0.04 sec)
-
android/guava-tests/test/com/google/common/primitives/UnsignedLongTest.java
for (long value : TEST_LONGS) { boolean expectSuccess = value >= 0; try { assertThat(UnsignedLong.valueOf(value).longValue()).isEqualTo(value); assertThat(expectSuccess).isTrue(); } catch (IllegalArgumentException e) { assertThat(expectSuccess).isFalse(); } } } public void testValueOfBigInteger() { BigInteger min = BigInteger.ZERO;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 02:56:12 UTC 2024 - 10.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
isThreadScheduled = true; scheduleEventRunner = true; } } if (scheduleEventRunner) { try { executor.execute(this); } catch (Exception e) { // sneaky checked exception // reset state in case of an error so that later dispatch calls will actually do something synchronized (this) { isThreadScheduled = false;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 8.2K bytes - Viewed (0) -
cmd/signature-v2_test.go
}, // (4) Should error when the signature does not match. { queryParams: map[string]string{ "Expires": fmt.Sprintf("%d", now.Unix()+60), "Signature": "badsignature", "AWSAccessKeyId": accessKey, }, expected: ErrSignatureDoesNotMatch, }, // (5) Should error when the signature does not match. { queryParams: map[string]string{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 14 10:08:40 UTC 2022 - 8K bytes - Viewed (0) -
ci/devinfra/docker/windows/Dockerfile
# This Dockerfile creates an image that has: # - the correct MTU setting for networking from inside the container to work. # - Visual Studio 2022 Build Tools # - MSVC 14.39 # - LLVM/Clang 18.1.4 # - MSYS2 + curl, git, patch, vim, unzip, zip # - Python 3.12.3 # - Bazelisk 1.19.0 # - JDK 21 (Azul Zulu) FROM mcr.microsoft.com/windows/servercore:ltsc2019 SHELL ["powershell.exe", "-ExecutionPolicy", "Bypass", "-Command", \
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Tue Aug 20 13:57:04 UTC 2024 - 7.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/score/ScoreUpdater.java
scoreBoosterList.forEach(b -> { try { final long count = b.process(); resultBuf.append(b.getClass().getSimpleName()).append(" : ").append(count).append('\n'); } catch (final Exception e) { logger.warn("Failed to update scores.", e); resultBuf.append(e.getMessage()).append('\n'); } }); return resultBuf.toString(); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 1.7K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/InterruptibleTask.java
@Override public void run() { T result = null; Throwable error = null; if (isDone()) { return; } try { result = runInterruptibly(); } catch (Throwable t) { error = t; } if (error == null) { // The cast is safe because of the `run` and `error` checks. afterRanInterruptiblySuccess(uncheckedCastNullableTToT(result)); } else {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Dec 08 20:30:27 UTC 2022 - 1.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/FilenameExtractor.java
} final String content = params.getOrDefault(ExtractData.RESOURCE_NAME_KEY, StringUtil.EMPTY); try { return new ExtractData(content); } catch (final Exception e) { throw new ExtractException(e); } }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 1.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/searchlog/SearchForm.java
if (value <= 0 || value > ComponentUtil.getFessConfig().getPageSearchlogMaxFetchSizeAsInteger()) { return SearchLogPager.DEFAULT_PAGE_SIZE; } return value; } catch (final NumberFormatException e) { // ignore return SearchLogPager.DEFAULT_PAGE_SIZE; } }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 1.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/SequentialExchangeFinder.kt
if (nextPlan != null) { routePlanner.deferredPlans.addFirst(nextPlan) continue } } return plan.handleSuccess() } catch (e: IOException) { if (firstException == null) { firstException = e } else { firstException.addSuppressed(e) } if (!routePlanner.hasNext()) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.8K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/AcceptedRegressionsRulePostProcess.java
if (!left.isEmpty()) { String formattedLeft = CollectionUtils.join("\n", left); throw new RuntimeException("The following regressions are declared as accepted, but didn't match any rule:\n\n" + formattedLeft); } }
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Jun 09 08:16:49 UTC 2021 - 1.7K bytes - Viewed (0)