- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 909 for chan (0.15 sec)
-
cmd/data-scanner_test.go
globalBucketObjectLockSys = &BucketObjectLockSys{} globalBucketVersioningSys = &BucketVersioningSys{} es := newExpiryState(context.Background(), objAPI, 0) workers := []chan expiryOp{make(chan expiryOp)} es.workers.Store(&workers) globalExpiryState = es var wg sync.WaitGroup wg.Add(1) expired := make([]ObjectToDelete, 0, 5) go func() { defer wg.Done()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/SingletonImmutableSet.java
import static com.google.common.base.Preconditions.checkNotNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * GWT emulation of {@link SingletonImmutableSet}. * * @author Hayward Chan */ @ElementTypesAreNonnullByDefault final class SingletonImmutableSet<E> extends ImmutableSet<E> { // This reference is used both by the custom field serializer, and by the
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jan 23 18:43:40 GMT 2024 - 1.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/Platform.java
*/ package com.google.common.collect.testing.testers; import com.google.common.annotations.GwtCompatible; import java.util.Locale; /** * This class is emulated in GWT. * * @author Hayward Chan */ @GwtCompatible final class Platform { /** Format the template with args, only supports the placeholder {@code %s}. */ static String format(String template, Object... args) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 1.3K bytes - Viewed (0) -
cmd/batch-handlers.go
ctx: ctx, objLayer: o, jobCh: make(chan *BatchJobRequest, 10000), workerKillCh: make(chan struct{}, workers), jobCancelers: make(map[string]context.CancelFunc), } jpool.ResizeWorkers(workers) jpool.resume() return jpool } func (j *BatchJobPool) resume() { results := make(chan ObjectInfo, 100) ctx, cancel := context.WithCancel(j.ctx) defer cancel()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/speedtest.go
} // Get the max throughput and iops numbers. func objectSpeedTest(ctx context.Context, opts speedTestOpts) chan madmin.SpeedTestResult { ch := make(chan madmin.SpeedTestResult, 1) go func() { defer xioutil.SafeClose(ch) concurrency := opts.concurrencyStart if opts.autotune { // if we have less drives than concurrency then choose // only the concurrency to be number of drives to start
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 9K bytes - Viewed (0) -
internal/event/target/nsq.go
initOnce once.Init id event.TargetID args NSQArgs producer *nsq.Producer store store.Store[event.Event] config *nsq.Config loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *NSQTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target. func (target *NSQTarget) Name() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 7.1K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableEnumSet.java
package com.google.common.collect; import java.util.Set; /** * GWT emulation of {@link ImmutableEnumSet}. The type parameter is not bounded by {@code Enum<E>} * to avoid code-size bloat. * * @author Hayward Chan */ @ElementTypesAreNonnullByDefault final class ImmutableEnumSet<E> extends ForwardingImmutableSet<E> { static <E> ImmutableSet<E> asImmutable(Set<E> delegate) { switch (delegate.size()) { case 0:
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jan 23 18:43:40 GMT 2024 - 1.3K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/SingletonImmutableList.java
import static java.util.Collections.singletonList; import java.util.List; /** * GWT emulated version of {@link SingletonImmutableList}. * * @author Hayward Chan */ @ElementTypesAreNonnullByDefault final class SingletonImmutableList<E> extends ForwardingImmutableList<E> { final transient List<E> delegate;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jan 23 18:43:40 GMT 2024 - 1.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ForwardingMultimapTest.java
import com.google.common.testing.EqualsTester; import com.google.common.testing.ForwardingWrapperTester; import junit.framework.TestCase; /** * Unit test for {@link ForwardingMultimap}. * * @author Hayward Chan */ public class ForwardingMultimapTest extends TestCase { @SuppressWarnings("rawtypes") public void testForwarding() { new ForwardingWrapperTester() .testForwarding( Multimap.class,
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 20:09:59 GMT 2024 - 1.8K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/RegularImmutableList.java
import static java.util.Collections.unmodifiableList; import java.util.List; import org.checkerframework.checker.nullness.qual.Nullable; /** * GWT emulated version of {@link RegularImmutableList}. * * @author Hayward Chan */ @ElementTypesAreNonnullByDefault class RegularImmutableList<E> extends ForwardingImmutableList<E> { static final ImmutableList<Object> EMPTY = new RegularImmutableList<Object>(emptyList());
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jan 23 18:43:40 GMT 2024 - 1.4K bytes - Viewed (0)