- Sort Score
- Num 10 results
- Language All
Results 221 - 230 of 303 for isSynchronized (0.07 seconds)
-
src/test/java/org/codelibs/fess/exception/UserRoleLoginExceptionTest.java
// Test thread safety of fillInStackTrace method UserRoleLoginException exception = new UserRoleLoginException(RootAction.class); // Create multiple threads to test synchronized method Thread thread1 = new Thread(() -> { Throwable result = exception.fillInStackTrace(); assertNull(result); }); Thread thread2 = new Thread(() -> {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 11K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
} } private static final class TimeoutFutureException extends TimeoutException { private TimeoutFutureException(String message) { super(message); } @Override public synchronized Throwable fillInStackTrace() { setStackTrace(new StackTraceElement[0]); return this; // no stack trace, wouldn't be useful anyway } } @OverrideCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 8K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbTreeHandleImpl.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 11.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt
while (true) { var tryAgain = false var readBytesDelivered = -1L var errorExceptionToDeliver: IOException? = null // 1. Decide what to do in a synchronized block. withLock { val doReadTimeout = doReadTimeout() if (doReadTimeout) { readTimeout.enter() } try {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jul 07 18:57:05 GMT 2025 - 22.4K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/project/interpolation/AbstractStringBasedModelInterpolator.java
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 13.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java
this.indexName = indexName; supportedFields = settings.array().get(SuggestSettings.DefaultKeys.SUPPORTED_FIELDS); totalDocNum = getTotal(); } @Override public synchronized Map<String, Object> read() { while (!isFinished.get() && queue.isEmpty()) { addDocumentToQueue(); } return queue.poll(); } @OverrideCreated: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Mon Nov 24 03:40:05 GMT 2025 - 11.1K bytes - Click Count (0) -
guava-testlib/src/com/google/common/collect/testing/TestsForSetsInJavaUtil.java
.suppressing(suppressForEnumSet()) .createTestSuite(); } /** * Tests regular NavigableSet behavior of synchronizedNavigableSet(treeSet); does not test the * fact that it's synchronized. */ public Test testsForSynchronizedNavigableSet() { return NavigableSetTestSuiteBuilder.using( new TestStringSortedSetGenerator() { @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Feb 19 21:24:11 GMT 2025 - 19.8K bytes - Click Count (0) -
src/test/java/jcifs/smb/PreauthIntegrityTest.java
when(address.getHostName()).thenReturn("testhost"); transport = new SmbTransportImpl(context, address, 445, null, 0, false); } /** * Test that pre-auth integrity hash is properly synchronized */ @Test @DisplayName("Pre-auth integrity hash should be thread-safe") void testPreauthHashThreadSafety() throws Exception { // Setup SMB3.1.1 negotiation
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 10.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/exec/SuggestCreator.java
} logger.info("Finished SuggestCreator."); System.exit(exitCode); } private static void destroyContainer() { TimeoutManager.getInstance().stop(); synchronized (SingletonLaContainerFactory.class) { SingletonLaContainerFactory.destroy(); } } private static int process(final Options options) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 12.1K bytes - Click Count (0) -
src/test/java/jcifs/SmbWatchHandleTest.java
private final Object lock = new Object(); private int watchCount = 0; @Override public List<FileNotifyInformation> watch() throws CIFSException { synchronized (lock) { watchCount++; try { // Simulate some processing time Thread.sleep(10);
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 13.2K bytes - Click Count (1)