- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 635 for Spread (0.04 sec)
-
src/test/java/jcifs/tests/persistent/HandleInfoTest.java
null); assertFalse(durableInfo.isExpired()); // Wait for expiration try { Thread.sleep(150); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } assertTrue(durableInfo.isExpired()); // Test persistent handle (never expires)
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 04:51:33 UTC 2025 - 4.6K bytes - Viewed (0) -
src/test/java/jcifs/util/SimpleCircuitBreakerTest.java
@RepeatedTest(10) @DisplayName("Test thread safety") void testThreadSafety() throws InterruptedException { SimpleCircuitBreaker breaker = new SimpleCircuitBreaker("concurrent", 5, 3, 100); AtomicInteger successCount = new AtomicInteger(0); AtomicInteger failureCount = new AtomicInteger(0); // Create multiple threads Thread[] threads = new Thread[10];
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 10.6K bytes - Viewed (0) -
src/test/java/jcifs/smb/NtlmPasswordAuthenticatorTest.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 23.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/Smb2EchoRequestTest.java
@DisplayName("Should maintain thread safety") void testThreadSafety() throws InterruptedException { int threadCount = 10; Thread[] threads = new Thread[threadCount]; boolean[] success = new boolean[threadCount]; for (int i = 0; i < threadCount; i++) { final int index = i; threads[i] = new Thread(() -> { try {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 11.3K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.8.md
#### [alpha] Federated Jobs Federated Jobs that are automatically deployed to multiple clusters are now supported. Cluster selection and weighting determine how Job parallelism and completions are spread across clusters. Federated Job status reflects the aggregate status across all underlying cluster jobs. #### [alpha] Federated Horizontal Pod Autoscaling (HPA)
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 312.2K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.9.md
### **API Machinery** * The kube-apiserver `--etcd-quorum-read` flag is deprecated and the ability to switch off quorum read will be removed in a future release. ([#53795](https://github.com/kubernetes/kubernetes/pull/53795),[ @xiangpengzhao](https://github.com/xiangpengzhao))
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Tue Nov 16 10:46:27 UTC 2021 - 313.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
.connectionPool(ConnectionPool(connectionListener = connectionListener)) } private fun loomThreadFactory(): ThreadFactory { val ofVirtual = Thread::class.java.getMethod("ofVirtual").invoke(null) return Class .forName("java.lang.Thread\$Builder") .getMethod("factory") .invoke(ofVirtual) as ThreadFactory }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 10.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TestLocking.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 4.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/RequestWithFileIdTest.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 11.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/NameServiceClient.java
// be ignored; see tryClose comment. if (socket == null) { socket = new DatagramSocket(lport, laddr); thread = new Thread(this, "JCIFS-NameServiceClient"); thread.setDaemon(true); thread.start(); } } void tryClose() { synchronized (LOCK) { /* Yes, there is the potential to drop packets
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 17.6K bytes - Viewed (0)