- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 117 for pickers (0.2 sec)
-
android/guava/src/com/google/common/cache/LocalCache.java
this.maxWeight = maxWeight; this.weigher = weigher; this.concurrencyLevel = concurrencyLevel; this.removalListener = removalListener; this.ticker = (ticker == Ticker.systemTicker() || ticker == NULL_TICKER) ? null : ticker; this.loader = loader; } CacheBuilder<K, V> recreateCacheBuilder() { CacheBuilder<K, V> builder = CacheBuilder.newBuilder()
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 144.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheBuilderSpecTest.java
assertEquals("valueStrength", a.valueStrength, b.valueStrength); assertEquals("statsCounterSupplier", a.statsCounterSupplier, b.statsCounterSupplier); assertEquals("ticker", a.ticker, b.ticker); assertEquals("recordStats", a.isRecordingStats(), b.isRecordingStats()); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 19.2K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/FreshValueGeneratorTest.java
import com.google.common.base.Equivalence; import com.google.common.base.Function; import com.google.common.base.Joiner; import com.google.common.base.Predicate; import com.google.common.base.Splitter; import com.google.common.base.Ticker; import com.google.common.collect.ArrayListMultimap; import com.google.common.collect.BiMap; import com.google.common.collect.HashBasedTable; import com.google.common.collect.HashBiMap;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 17.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/Kerb5Authenticator.java
* first one will be used to retrieve user principal. * * @param subject * represents the user who perform Kerberos authentication. * It contains tickets retrieve from KDC. */ public Kerb5Authenticator ( Subject subject ) { this.subject = subject; } /**
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 13K bytes - Viewed (0) -
cmd/tier-journal.go
if err != nil { return err } return nil } func (jd *tierDiskJournal) deletePending(ctx context.Context) { ticker := time.NewTicker(30 * time.Minute) defer ticker.Stop() for { select { case <-ticker.C: jd.WalkEntries(ctx, deleteObjectFromRemoteTier) case <-ctx.Done(): jd.Close() return } } }
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java
import com.google.common.base.Equivalence; import com.google.common.base.Joiner; import com.google.common.base.Predicate; import com.google.common.base.Splitter; import com.google.common.base.Stopwatch; import com.google.common.base.Ticker; import com.google.common.collect.BiMap; import com.google.common.collect.ClassToInstanceMap; import com.google.common.collect.ImmutableBiMap; import com.google.common.collect.ImmutableClassToInstanceMap;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/android/ConscryptSocketAdapter.kt
sslSocket: SSLSocket, hostname: String?, protocols: List<Protocol>, ) { // No TLS extensions if the socket class is custom. if (matchesSocket(sslSocket)) { // Enable session tickets. Conscrypt.setUseSessionTickets(sslSocket, true) // Enable ALPN. val names = Platform.alpnProtocolNames(protocols) Conscrypt.setApplicationProtocols(sslSocket, names.toTypedArray()) } }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.2K bytes - Viewed (0) -
cmd/site-replication-metrics.go
ReplicaSize int64 `json:"replicaSize"` // Total Replica received ReplicaCount int64 `json:"replicaCount"` M map[string]*SRStatus `json:"srStatusMap"` movingAvgTicker *time.Ticker // Ticker for calculating moving averages lock sync.RWMutex // mutex for srStats } // SRStatus has replication stats at deployment level type SRStatus struct {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
internal/grid/muxclient.go
if m.respErr.Load() == nil { xioutil.SafeClose(respHandler) } }() var pingTimer <-chan time.Time if m.deadline == 0 || m.deadline > clientPingInterval { ticker := time.NewTicker(clientPingInterval) defer ticker.Stop() pingTimer = ticker.C atomic.StoreInt64(&m.LastPong, time.Now().Unix()) } defer m.parent.deleteMux(false, m.MuxID) for { select { case <-m.ctx.Done(): if debugPrint {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/prepare-storage.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0)