- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for Chan (0.2 sec)
-
cmd/bucket-replication.go
mrfMU sync.Mutex resyncer *replicationResyncer // workers: workers []chan ReplicationWorkerOperation lrgworkers []chan ReplicationWorkerOperation // mrf: mrfWorkerKillCh chan struct{} mrfReplicaCh chan ReplicationWorkerOperation mrfSaveCh chan MRFReplicateEntry mrfStopCh chan struct{} mrfWorkerSize int }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 112K bytes - Viewed (1) -
doc/go1.17_spec.html
<-chan <-chan int // same as <-chan (<-chan int) chan (<-chan int) </pre> <p> A new, initialized channel value can be made using the built-in function <a href="#Making_slices_maps_and_channels"><code>make</code></a>, which takes the channel type and an optional <i>capacity</i> as arguments: </p> <pre> make(chan int, 100) </pre> <p>
HTML - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Thu Apr 11 20:22:45 GMT 2024 - 211.6K bytes - Viewed (0) -
cmd/metrics-v2.go
func (c *minioBucketCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc } // Collect is called by the Prometheus registry when collecting metrics. func (c *minioBucketCollector) Collect(out chan<- prometheus.Metric) { var wg sync.WaitGroup publish := func(in <-chan MetricV2) { defer wg.Done() for metric := range in {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 11 21:22:15 GMT 2024 - 132.1K bytes - Viewed (0) -
src/cmd/cgo/internal/test/callback.go
// variadic call mallocs + writes to variadic(x, x, x) if x != 1 { panic("bad x") } } } func variadic(x ...interface{}) {} func testBlocking(t *testing.T) { c := make(chan int) go func() { for i := 0; i < 10; i++ { c <- <-c } }() nestedCall(func() { for i := 0; i < 10; i++ { c <- i if j := <-c; j != i { t.Errorf("out of sync %d != %d", j, i)
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri May 12 12:00:02 GMT 2023 - 111.5K bytes - Viewed (0) -
okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat
aetna // afl : 2014-10-02 Australian Football League afl // africa : 2014-03-24 ZA Central Registry NPC trading as Registry.Africa africa // agakhan : 2015-04-23 Fondation Aga Khan (Aga Khan Foundation) agakhan // agency : 2013-11-14 Binky Moon, LLC agency // aig : 2014-12-18 American International Group, Inc. aig // airbus : 2015-07-30 Airbus S.A.S. airbus
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 240.3K bytes - Viewed (3) -
src/main/java/org/codelibs/fess/es/config/cbean/cq/bs/BsFileConfigCQ.java
public void setAvailable_GreaterThan(Boolean available, ConditionOptionCall<RangeQueryBuilder> opLambda) { final Object _value = available; RangeQueryBuilder builder = regRangeQ("available", ConditionKey.CK_GREATER_THAN, _value); if (opLambda != null) { opLambda.callback(builder); } } public void setAvailable_LessThan(Boolean available) { setAvailable_LessThan(available, null);
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 165.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
Just then her head struck against the roof of the hall: in fact she was now more than nine feet high, and she at once took up the little golden key and hurried off to the garden door. Poor Alice! It was as much as she could do, lying down on one side, to look through into the garden with one eye; but to get through was more hopeless than ever: she sat down and began to cry again.
Plain Text - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri Apr 21 02:27:51 GMT 2017 - 145.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/cbean/cq/bs/BsScheduledJobCQ.java
public void setAvailable_GreaterThan(Boolean available, ConditionOptionCall<RangeQueryBuilder> opLambda) { final Object _value = available; RangeQueryBuilder builder = regRangeQ("available", ConditionKey.CK_GREATER_THAN, _value); if (opLambda != null) { opLambda.callback(builder); } } public void setAvailable_LessThan(Boolean available) { setAvailable_LessThan(available, null);
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 98.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/log/cbean/cq/bs/BsSearchLogCQ.java
public void setAccessType_GreaterThan(String accessType, ConditionOptionCall<RangeQueryBuilder> opLambda) { final Object _value = accessType; RangeQueryBuilder builder = regRangeQ("accessType", ConditionKey.CK_GREATER_THAN, _value); if (opLambda != null) { opLambda.callback(builder); } } public void setAccessType_LessThan(String accessType) { setAccessType_LessThan(accessType, null);
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 145.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/cbean/cq/bs/BsWebConfigCQ.java
public void setAvailable_GreaterThan(Boolean available, ConditionOptionCall<RangeQueryBuilder> opLambda) { final Object _value = available; RangeQueryBuilder builder = regRangeQ("available", ConditionKey.CK_GREATER_THAN, _value); if (opLambda != null) { opLambda.callback(builder); } } public void setAvailable_LessThan(Boolean available) { setAvailable_LessThan(available, null);
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 172.1K bytes - Viewed (0)