Generally, googling your question before posting it here is recommended. I’ve found a potential resource for you here: http://libcwd.sourceforge.net/reference-manual/group__group__debug__channels.html And here: http://libcwd.sourceforge.net/tutorial/tut2.html I’m not a C++ specialist but those seem to be the answer you’re looking for. solved What is Debug Channel?
I haven’t analyzed all of it, but definitely the modification of mapStore from multiple goroutines is unsafe: mapStore[*res.someData] = append(mapStore[*res.someData], res) But as a starting point, run this under the race detector. It’ll find many problems for you. This is also clearly unsafe: resSlice := append(resSlice, res) But it also doesn’t quite do what you … Read more
Those two lines in your main function shadow your global variable declaration: optQuit := getopt.BoolLong(“quit”, 0, “Help”) optRun := getopt.BoolLong(“run”, ‘r’, “Help”) If you only use them, to get a nice usage, why not create a usage function yourself? If you insist on using getopt just to create a usage, do _ = getopt.BoolLong(“quit”, 0, … Read more
You can’t kill a goroutine from outside – you can’t even reference a specific goroutine; nor can you abort a blocking operation. You can, however, move the for to the outside: go func() { for { select { case close := <-closeChan: return 0 case i,ok := <-c: // do stuff if !ok { // … Read more
The select statement chooses a case whose communication op would not block. If there are multiple cases whose comm. op would not block, one is chosen randomly. Since in the example all communication ops would block, and since a default is provided, that will be executed. To “trigger” another case, you have to make sure … Read more
First, you declared Consumer as a chan of interface{ /* methods */ }, which most surely isn’t what you want — as a matter of fact, the error tells that you can’t assign IntChannel to it. Then, until generics are added to the language, you don’t have a way to preserve type safety. The closest … Read more