- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for GetNonBlocking (0.17 sec)
-
internal/once/singleton.go
} // Get will return the singleton value. func (s *Singleton[T]) Get() *T { <-s.set return s.v } // GetNonBlocking will return the singleton value or nil if not set yet. func (s *Singleton[T]) GetNonBlocking() *T { select { case <-s.set: return s.v default: return nil } } // IsSet will return whether the singleton has been set.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 952 bytes - Viewed (0) -
cmd/handler-api.go
t.requestsPool = make(chan struct{}, apiRequestsMaxPerNode) } listQuorum := cfg.ListQuorum if listQuorum == "" { listQuorum = "strict" } t.listQuorum = listQuorum if r := globalReplicationPool.GetNonBlocking(); r != nil && (cfg.ReplicationPriority != t.replicationPriority || cfg.ReplicationMaxWorkers != t.replicationMaxWorkers || cfg.ReplicationMaxLWorkers != t.replicationMaxLWorkers) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 17:07:10 UTC 2024 - 10.4K bytes - Viewed (0)