- Sort Score
- Num 10 results
- Language All
Results 461 - 470 of 890 for thread (0.31 seconds)
-
android/guava/src/com/google/common/io/FileBackedOutputStream.java
* #FileBackedOutputStream(int, boolean) the two-arg constructor} with {@code true} for the * second parameter. Relying on this second approach is discouraged. * </ul> * * <p>This class is thread-safe. * * @author Chris Nokleberg * @since 1.0 */ @Beta @J2ktIncompatible @GwtIncompatible @J2ObjCIncompatible public final class FileBackedOutputStream extends OutputStream {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 17:30:49 GMT 2026 - 12.4K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbCopyUtil.java
} w.checkException(); if (read <= 0) { break; } w.write(b[i], read, fos); } i = i == 1 ? 0 : 1; off += read; } if (log.isDebugEnabled()) {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 16.6K bytes - Click Count (0) -
src/main/java/org/codelibs/core/lang/ClassUtil.java
*/ public static <T> Class<T> forName(final String className) throws ClassNotFoundRuntimeException { assertArgumentNotEmpty("className", className); return forName(className, Thread.currentThread().getContextClassLoader()); } /** * Returns the {@link Class} object associated with the class or interface with the given string name, * using the specified class loader. *Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Jul 31 08:16:49 GMT 2025 - 25.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
try { transformResult = doTransform(localFunction, sourceResult); } catch (Throwable t) { restoreInterruptIfIsInterruptedException(t); // This exception is irrelevant in this thread, but useful for the client. setException(t); return; } finally { function = null; } /* * If set()/setValue() throws an Error, we let it propagate. Why? The most likely Error is aCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Feb 20 18:03:37 GMT 2025 - 10.8K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Sets.java
} /** * Creates a thread-safe set backed by a hash map. The set is backed by a {@link * ConcurrentHashMap} instance, and thus carries the same concurrency guarantees. * * <p>Unlike {@code HashSet}, this class does NOT allow {@code null} to be used as an element. The * set is serializable. * * @return a new, empty thread-safe {@code Set} * @since 15.0 */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 81.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/MoreFilesTest.java
MoreFiles.deleteDirectoryContents(symlink, ALLOW_INSECURE); assertEquals(0, MoreFiles.listFiles(dir).size()); } } /** * This test attempts to create a situation in which one thread is constantly changing a file from * being a real directory to being a symlink to another directory. It then calls * deleteDirectoryContents thousands of times on a directory whose subtree contains the fileCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 26.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/Constants.java
public static final String INCREMENTAL_CRAWLING_PROPERTY = "crawling.incremental"; /** Property key for crawling thread count configuration. */ public static final String CRAWLING_THREAD_COUNT_PROPERTY = "crawling.thread.count"; /** Property key for crawling user agent configuration. */ public static final String CRAWLING_USER_AGENT_PROPERTY = "crawling.user.agent";
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 11:55:54 GMT 2026 - 35.8K bytes - Click Count (0) -
README.md
- **Logging Abstraction** (`org.codelibs.core.log`) - Flexible logging system supporting JCL (Jakarta Commons Logging) and JUL (Java Util Logging) - **Concurrent Utilities** (`org.codelibs.core.concurrent`) - Thread-safe collections and concurrency helpers using modern concurrent APIs - **Crypto & Security** (`org.codelibs.core.crypto`, `org.codelibs.core.security`) - Basic cryptographic utilities, message digest operations, and secure random generation
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Sun Aug 31 02:56:02 GMT 2025 - 12.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java
int countToRemove = 30; AtomicInteger current = new AtomicInteger(countToRemove); when(backingMap.get(KEY)).thenReturn(current); // it's ok if removal fails: another thread may have done the remove when(backingMap.remove(KEY, current)).thenReturn(false); assertEquals(countToRemove, multiset.remove(KEY, countToRemove)); assertEquals(0, current.get()); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 16.3K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
// // TODO(user): Consider using // java/lang/management/OperatingSystemMXBean.html#getSystemLoadAverage() // // TODO(user): Consider scaling by number of mutator threads, // e.g. using Thread#activeCount() return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L)); } /**Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 20:19:19 GMT 2026 - 12.3K bytes - Click Count (0)