Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 803 for callEnd (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top