Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 680 for Threads (0.07 sec)

  1. android/guava/src/com/google/common/collect/Multimaps.java

        for (Map.Entry<? extends V, ? extends K> entry : source.entries()) {
          dest.put(entry.getValue(), entry.getKey());
        }
        return dest;
      }
    
      /**
       * Returns a synchronized (thread-safe) multimap backed by the specified multimap. In order to
       * guarantee serial access, it is critical that <b>all</b> access to the backing multimap is
       * accomplished through the returned multimap.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  2. internal/event/target/redis.go

    		if err != nil {
    			return err
    		}
    		if _, err := conn.Do("RPUSH", target.args.Key, data); err != nil {
    			return err
    		}
    	}
    
    	return nil
    }
    
    // SendFromStore - reads an event from store and sends it to redis.
    func (target *RedisTarget) SendFromStore(key store.Key) error {
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	conn := target.pool.Get()
    	defer conn.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  3. cmd/metrics-v3-system-process.go

    			metricsLogIf(ctx, err)
    		} else {
    			loadProcFSMetrics(ctx, p, m)
    		}
    	}
    
    	if globalIsDistErasure && globalLockServer != nil {
    		st := globalLockServer.stats()
    		m.Set(processLocksReadTotal, float64(st.Reads))
    		m.Set(processLocksWriteTotal, float64(st.Writes))
    	}
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  4. internal/s3select/simdj/reader.go

    	// err will only be returned after decoded has been closed.
    	err          *error
    	readCloser   io.ReadCloser
    	onReaderExit func()
    
    	exitReader chan struct{}
    	readerWg   sync.WaitGroup
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	v, ok := <-r.decoded
    	if !ok {
    		if r.err != nil && *r.err != nil {
    			return nil, errJSONParsingError(*r.err)
    		}
    		return nil, io.EOF
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  5. okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt

    private fun BufferedSource.skipRestOfLine() {
      when (val newline = indexOf('\n'.code.toByte())) {
        -1L -> skip(buffer.size) // Exhaust this source.
        else -> skip(newline + 1)
      }
    }
    
    /**
     * Reads lines from `IdnaMappingTable.txt`.
     *
     * Comment lines are either blank or start with a `#` character. Lines may also end with a comment.
     * All comments are ignored.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/collect/AbstractTableTest.java

    import java.util.Map;
    import org.checkerframework.checker.nullness.qual.NonNull;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Test cases for a {@link Table} implementation supporting reads and writes.
     *
     * @author Jared Levy
     * @author Louis Wasserman
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public abstract class AbstractTableTest<C extends @Nullable Character>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 15 17:36:06 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        checkNotNull(runnable, "Runnable was null.");
        checkNotNull(executor, "Executor was null.");
    
        // Lock while we check state. We must maintain the lock while adding the new pair so that
        // another thread can't run the list out from under us. We only add to the list if we have not
        // yet started execution.
        synchronized (this) {
          if (!executed) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 22 21:17:24 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 17:40:56 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  9. src/test/java/jcifs/tests/KerberosTest.java

                try ( SmbTreeHandle th = f.getTreeHandle() ) {
                    Assume.assumeTrue("Not SMB2", th.isSMB2());
                }
    
                f.exists();
                Thread.sleep(wait);
    
                try ( SmbResource r = f.resolve("test") ) {
                    r.exists();
                }
            }
            catch ( SmbUnsupportedOperationException e ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Mar 01 09:46:04 UTC 2020
    - 11.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/math/PairedStatsAccumulator.java

    import com.google.common.primitives.Doubles;
    
    /**
     * A mutable object which accumulates paired double values (e.g. points on a plane) and tracks some
     * basic statistics over all the values added so far. This class is not thread safe.
     *
     * @author Pete Gillin
     * @since 20.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    public final class PairedStatsAccumulator {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 17:02:53 UTC 2023
    - 10.3K bytes
    - Viewed (0)
Back to top