conc
conc copied to clipboard
sourcegraph
Better structured concurrency for go
Is it possible to add the wg.GoWithTimeout method, each coroutine needs to control the timeout period, or wg.WaitWithTimeout() The overall time-consuming control.
This adds the `WithCancelOnError()` configuration method to `ContextPool` and `ResultContextPool`, and changes the default behavior to not cancel the pool's context on error. `ContextPool` initially canceled by default because otherwise,...
As the open source program manager, I should have flagged this earlier. https://handbook.sourcegraph.com/departments/engineering/dev/process/licenses/
When we run batch tasks, sometimes an error in one subtask means that the whole task is wrong. So it is desirable to add the ability to exit on the...
When we run batch tasks, sometimes an error in one subtask means that the whole task is wrong. So it is desirable to add the ability to exit on the...
`Map` and `ForEach` currently use the `GOMAXPROCS` value to determine how many go routines run in parallel, but there's lots of situations (like making one network request per item in...
I've written https://github.com/sudhirj/cirque It basically takes a processing function and gives you an input and output channel, and inputs sent to the input channel and processed in parallel with the...
Resolves #29. 👋 My attempt at resolving #29. I wasn't sure if was better to reimplement `Wait` in terms of `WaitSafe`. I think leaving the code as it looks a...
