Search Options

Results per page
Sort
Preferred Languages
Advance

Results 671 - 680 of 801 for Threads (0.04 sec)

  1. 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.
       *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/storage/Handler.java

            /**
             * Establishes a connection to the storage service.
             * This method creates a MinIO client using environment variables for configuration.
             * This method is synchronized to ensure thread-safe connection initialization.
             *
             * @throws IOException If the connection cannot be established
             */
            @Override
            public synchronized void connect() throws IOException {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:52:56 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.base.Preconditions.checkArgument;
    import static java.lang.Thread.currentThread;
    import static java.util.Arrays.asList;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.annotations.VisibleForTesting;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/smb1/SigningDigest.java

            update(sequence, 0, sequence.length);
            index += 8;
            if (response.command == ServerMessageBlock.SMB_COM_READ_ANDX) {
                /* SmbComReadAndXResponse reads directly from the stream into separate byte[] b.
                 */
                final SmbComReadAndXResponse raxr = (SmbComReadAndXResponse) response;
                final int length = response.length - raxr.dataLength;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb/BufferCacheImplTest.java

    import jcifs.Configuration;
    
    @ExtendWith(MockitoExtension.class)
    class BufferCacheImplTest {
    
        @Mock
        Configuration cfg;
    
        // Verifies constructor that accepts Configuration reads the expected values and uses them
        @Test
        @DisplayName("Constructor(Configuration) uses cache size and maximum buffer size from config")
        void constructorUsesConfigurationAndAllocatesWithConfiguredSize() {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  6. cmd/metrics-v3-system-drive.go

    		"Count of online drives")
    	driveCountMD = NewGaugeMD(driveCount,
    		"Count of all drives")
    
    	// iostat related
    	driveReadsPerSecMD = NewGaugeMD(driveReadsPerSec,
    		"Reads per second on a drive",
    		allDriveLabels...)
    	driveReadsKBPerSecMD = NewGaugeMD(driveReadsKBPerSec,
    		"Kilobytes read per second on a drive",
    		allDriveLabels...)
    	driveReadsAwaitMD = NewGaugeMD(driveReadsAwait,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  7. cmd/metrics-v3-cache.go

    	return m
    }
    
    func newDriveMetricsCache() *cachevalue.Cache[storageMetrics] {
    	var (
    		// prevDriveIOStats is used to calculate "per second"
    		// values for IOStat related disk metrics e.g. reads/sec.
    		prevDriveIOStats            map[string]madmin.DiskIOStats
    		prevDriveIOStatsMu          sync.RWMutex
    		prevDriveIOStatsRefreshedAt time.Time
    	)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  8. internal/s3select/json/preader.go

    type queueItem struct {
    	input []byte             // raw input sent to the worker
    	dst   chan []jstream.KVS // result of block decode
    	err   error              // any error encountered will be set here
    }
    
    // Read - reads single record.
    // Once Read is called the previous record should no longer be referenced.
    func (r *PReader) Read(dst sql.Record) (sql.Record, error) {
    	// If we have have any records left, return these before any error.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  9. docs/SMB3_IMPLEMENTATION_PLAN.md

    jcifs.smb.client.witnessNotificationTimeout=5000
    ```
    
    ## Risk Assessment
    
    ### Technical Risks
    1. **RDMA Complexity**: Limited Java RDMA support may require JNI
    2. **Multi-Channel Synchronization**: Complex thread synchronization required
    3. **Persistent Handle State**: Requires reliable state persistence mechanism
    4. **Backward Compatibility**: Must maintain compatibility with SMB2/SMB1
    
    ### Mitigation Strategies
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 10.7K bytes
    - Viewed (0)
  10. 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;
        }
    
        /*
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
Back to top