- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 90 for sendErr (0.12 sec)
-
test/typeparam/orderedmapsimp.dir/a.go
func Ranger[Elem any]() (*Sender[Elem], *Receiver[Elem]) { c := make(chan Elem) d := make(chan struct{}) s := &Sender[Elem]{ values: c, done: d, } r := &Receiver[Elem]{ values: c, done: d, } runtime.SetFinalizer(r, (*Receiver[Elem]).finalize) return s, r } // A Sender is used to send values to a Receiver. type Sender[Elem any] struct { values chan<- Elem
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 28 21:40:40 UTC 2021 - 5.5K bytes - Viewed (0) -
src/net/smtp/example_test.go
"log" "net/smtp" ) func Example() { // Connect to the remote SMTP server. c, err := smtp.Dial("mail.example.com:25") if err != nil { log.Fatal(err) } // Set the sender and recipient first if err := c.Mail("sender@example.org"); err != nil { log.Fatal(err) } if err := c.Rcpt("******@****.***"); err != nil { log.Fatal(err) } // Send the email body. wc, err := c.Data()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Feb 07 22:23:10 UTC 2015 - 1.9K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/process/internal/CrashingRemoteProcess.java
public void execute(WorkerProcessContext workerProcessContext) { TestListenerInterface sender = workerProcessContext.getServerConnection().addOutgoing(TestListenerInterface.class); workerProcessContext.getServerConnection().connect(); sender.send("message 1", 1); sender.send("message 2", 2); // crash Runtime.getRuntime().halt(1234); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Feb 21 14:14:00 UTC 2017 - 1.2K bytes - Viewed (0) -
test/chan/doubleselect.go
package main import ( "flag" "runtime" ) var iterations *int = flag.Int("n", 100000, "number of iterations") // sender sends a counter to one of four different channels. If two // cases both end up running in the same iteration, the same value will be sent // to two different channels. func sender(n int, c1, c2, c3, c4 chan<- int) { defer close(c1) defer close(c2) defer close(c3) defer close(c4)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 24 01:34:14 UTC 2017 - 2K bytes - Viewed (0) -
src/cmd/cgo/internal/testsanitizers/testdata/tsan15.go
go_callback(); return 0; } static void *sendthr(void *arg) { pthread_t th = *(pthread_t*)arg; while (1) { int r = pthread_kill(th, SIGWINCH); if (r < 0) break; } return 0; } static void foo() { pthread_t *th = malloc(sizeof(pthread_t)); pthread_t th2; pthread_create(th, 0, thr, 0); pthread_create(&th2, 0, sendthr, th); pthread_join(*th, 0); } */ import "C"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 06 21:14:49 UTC 2024 - 968 bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/process/internal/OtherRemoteProcess.java
public void execute(WorkerProcessContext workerProcessContext) { TestListenerInterface sender = workerProcessContext.getServerConnection().addOutgoing(TestListenerInterface.class); workerProcessContext.getServerConnection().connect(); sender.send("other 1", 1); sender.send("other 2", 2); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 06 17:14:50 UTC 2016 - 1.2K bytes - Viewed (0) -
test/chan/select2.go
runtime.MemProfileRate = 0 c := make(chan int) dummy := make(chan int) // warm up go sender(c, 100000) receiver(c, dummy, 100000) runtime.GC() memstats := new(runtime.MemStats) runtime.ReadMemStats(memstats) alloc := memstats.Alloc // second time shouldn't increase footprint by much go sender(c, 100000) receiver(c, dummy, 100000) runtime.GC() runtime.ReadMemStats(memstats)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 1K bytes - Viewed (0) -
src/runtime/chan.go
} return true, false } // The channel has been closed, but the channel's buffer have data. } else { // Just found waiting sender with not closed. if sg := c.sendq.dequeue(); sg != nil { // Found a waiting sender. If buffer is size 0, receive value // directly from sender. Otherwise, receive from head of queue // and add sender's value to the tail of the queue (both map to
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/testdata/map2.go
func (m *Map[K, V]) InOrder() *Iterator[K, V] { sender, receiver := chans_Ranger[keyValue[K, V]]() var f func(*node[K, V]) bool f = func(n *node[K, V]) bool { if n == nil { return true } // Stop sending values if sender.Send returns false, // meaning that nothing is listening at the receiver end. return f(n.left) && sender.Send(keyValue[K, V]{n.key, n.val}) && f(n.right) } go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 01 12:49:49 UTC 2023 - 3.4K bytes - Viewed (0) -
src/internal/types/testdata/check/map1.go
func (m *Map[K, V]) InOrder() *Iterator[K, V] { sender, receiver := chans_Ranger[keyValue[K, V]]() var f func(*node[K, V]) bool f = func(n *node[K, V]) bool { if n == nil { return true } // Stop sending values if sender.Send returns false, // meaning that nothing is listening at the receiver end. return f(n.left) && sender.Send(keyValue[K, V]{n.key, n.val}) && f(n.right) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 02 02:58:32 UTC 2022 - 3.4K bytes - Viewed (0)