- Sort Score
- Num 10 results
- Language All
Results 441 - 450 of 890 for thread (0.04 seconds)
-
README.md
**Suggestions Not Appearing** - Confirm documents are indexed: `suggester.refresh()` - Check query formatting and filters - Verify analyzer configurations **Performance Issues** - Increase thread pool size in SuggesterBuilder - Optimize batch sizes for indexing operations - Review OpenSearch cluster performance **Memory Usage** - Configure appropriate JVM heap settings
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Aug 31 03:31:14 GMT 2025 - 12.1K bytes - Click Count (1) -
src/test/java/jcifs/SmbSessionTest.java
java.util.concurrent.atomic.AtomicInteger successCount = new java.util.concurrent.atomic.AtomicInteger(0); for (int i = 0; i < 5; i++) { new Thread(() -> { try { Configuration result = mockSession.getConfig(); if (result == mockConfig) { successCount.incrementAndGet();
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 15.1K bytes - Click Count (0) -
build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java
ByteArrayOutputStream os = new ByteArrayOutputStream(); PrintStream ps = new PrintStream(os, true); new Thread(() -> { try { BufferedReader reader = new BufferedReader(new InputStreamReader(forkedProcessOutput, UTF_8)); String line;
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Sep 23 13:49:45 GMT 2025 - 12K bytes - Click Count (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/package-info.java
* * <p>The {@link org.apache.maven.api.Session} interface is the main entry point for Maven operations. * It maintains the state of a Maven execution and provides access to all core services and components. * Sessions are thread-safe and can be obtained in session-scoped components using the * {@link org.apache.maven.api.di.SessionScoped} annotation.</p> * * <p>Key capabilities provided through the Session include:</p> * <ul>Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Mon Dec 15 11:13:42 GMT 2025 - 7.7K bytes - Click Count (0) -
src/main/java/jcifs/util/SecureCredentialStorage.java
* using AES-GCM encryption with PBKDF2 key derivation. * * Features: * - Encrypts credentials at rest using AES-256-GCM * - Uses PBKDF2 for key derivation from master password * - Secure wiping of sensitive data * - Thread-safe operations * - Protection against timing attacks */ public class SecureCredentialStorage implements AutoCloseable, Destroyable {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 12.7K bytes - Click Count (0) -
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 - 27.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* @param executor the executor in which the listeners callback methods will be run. For fast, * lightweight listeners that would be safe to execute in any thread, consider {@link * MoreExecutors#directExecutor}. * @since 13.0 */ void addListener(Listener listener, Executor executor); /** * The lifecycle states of a service. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 10.8K bytes - Click Count (0) -
guava/src/com/google/common/cache/CacheLoader.java
* @throws InterruptedException if this method is interrupted. {@code InterruptedException} is * treated like any other {@code Exception} in all respects except that, when it is caught, * the thread's interrupted status is set */ public abstract V load(K key) throws Exception; /** * Computes or retrieves a replacement value corresponding to an already-cached {@code key}. ThisCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 9.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
// executing listeners in the order they were added // 3. push all the items onto 'onto' and return the new head of the stack Listener head = gasListeners(Listener.TOMBSTONE); Listener reversedList = onto; while (head != null) { Listener tmp = head; head = head.next; tmp.next = reversedList; reversedList = tmp; } return reversedList; }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 14:39:00 GMT 2026 - 43.6K bytes - Click Count (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
assertThat(inputStream.read()).isEqualTo('A'.code) assertThat(inputStream.read()).isEqualTo('B'.code) assertThat(inputStream.read()).isEqualTo('C'.code) assertThat(inputStream.read()).isEqualTo('D'.code) assertThat(inputStream.read()).isEqualTo('E'.code) assertThat(inputStream.read()).isEqualTo('F'.code) assertThat(inputStream.read()).isEqualTo(-1)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 03 13:16:34 GMT 2025 - 22.3K bytes - Click Count (0)