- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 803 for callEnd (0.24 sec)
-
src/test/java/jcifs/internal/smb1/com/SmbComTreeDisconnectTest.java
smbComTreeDisconnect = new SmbComTreeDisconnect(config); byte[] buffer = new byte[1000]; int numThreads = 10; Thread[] threads = new Thread[numThreads]; // When - multiple threads calling methods simultaneously for (int i = 0; i < numThreads; i++) { final int threadIndex = i; threads[i] = new Thread(() -> { for (int j = 0; j < 100; j++) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 18.5K bytes - Viewed (0) -
docs/en/docs/async.md
But by following the steps above, it will be able to do some performance optimizations. ## Technical Details { #technical-details } Modern versions of Python have support for **"asynchronous code"** using something called **"coroutines"**, with **`async` and `await`** syntax. Let's see that phrase by parts in the sections below: * **Asynchronous Code** * **`async` and `await`** * **Coroutines**
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:56:21 UTC 2025 - 24K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/base/FessBaseAction.java
// to suppress unexpected override by sub-class // you should remove the 'final' if you need to override this /** * Hook method called before action execution. * This method refreshes the user information if a user is logged in * and delegates to the view helper's action hook. * * @param runtime the action runtime context
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 15K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Finish the task by unblocking the task latch. Then wait for the // listener to be called by blocking on the listener latch. taskLatch.countDown(); assertEquals(25, task.get().intValue()); assertTrue(listenerLatch.await(5, SECONDS)); assertTrue(task.isDone());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 4.8K bytes - Viewed (0) -
src/test/java/jcifs/dcerpc/msrpc/SamrAliasHandleTest.java
// Act aliasHandle.close(); // Assert // Verify that sendrecv was called with MsrpcSamrCloseHandle verify(mockDcerpcHandle).sendrecv(any(MsrpcSamrCloseHandle.class)); // Verify that close was called only once on the mockDcerpcHandle for MsrpcSamrCloseHandle verify(mockDcerpcHandle, times(1)).sendrecv(any(MsrpcSamrCloseHandle.class)); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 6.2K bytes - Viewed (0) -
src/test/java/jcifs/dcerpc/msrpc/MsrpcLsarOpenPolicy2Test.java
// When MsrpcLsarOpenPolicy2 msrpcLsarOpenPolicy2 = new MsrpcLsarOpenPolicy2(server, access, mockPolicyHandle); // Then // Verify that the super constructor is called with correct arguments // Note: Directly verifying super constructor calls is not straightforward in JUnit/Mockito. // We verify the effects of the super constructor by checking the fields of the created object.
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 2.1K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
inputHeader.Set("X-Amz-Meta-Name", expectedMetaName) // calling the function being tested. errCode := checkMetaHeaders(signedHeadersMap, r) if errCode != ErrNone { t.Fatalf("Expected the APIErrorCode to be %d, but got %d", ErrNone, errCode) } // Add new metadata in inputHeader inputHeader.Set("X-Amz-Meta-Clone", "fail") // calling the function being tested. errCode = checkMetaHeaders(signedHeadersMap, r)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 14.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
boolean[] called = new boolean[1]; f.addCallback( new FutureCallback<String>() { @Override public void onSuccess(String result) { called[0] = true; } @Override public void onFailure(Throwable t) {} }, directExecutor()); assertThat(called[0]).isTrue(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 5.8K bytes - Viewed (0) -
src/main/java/jcifs/context/SingletonContext.java
private static SingletonContext INSTANCE; /** * Initialize singleton context using custom properties * * This method can only be called once. * * @param props the properties to use for initialization * @throws CIFSException if the singleton context is already initialized or there is an error during initialization */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java
private boolean called = false; @Override public void onSuccess(String result) { fail("Was not expecting onSuccess() to be called."); } @Override public void onFailure(Throwable t) { synchronized (monitor) { assertFalse(called); assertThat(t).isInstanceOf(CancellationException.class);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 6.7K bytes - Viewed (0)