multithreading - How to implement multithreaded AbortJob? -
i have implemented following go routines
func main() { go processjob(job) } func processjob() { task := range tasks go performtask(task) } } func performtask(task) { sub := range task { go perfromsubtask(sub) } } func performsubtask(sub) error { // }
now want implement abortjob() such if pass jobid abortjob using channels, routines should stop tasks , exits gracefully. how in go?
Comments
Post a Comment