登录
首页 >  Golang >  Go问答

是否有一些优雅的方式来暂停和恢复任何其他 goroutine?

来源:Golang技术栈

时间:2023-04-11 22:35:07 455浏览 收藏

IT行业相对于一般传统行业,发展更新速度更快,一旦停止了学习,很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习,精进自己的技术,尤其是初学者。今天golang学习网给大家整理了《是否有一些优雅的方式来暂停和恢复任何其他 goroutine?》,聊聊golang,我们一起来看看吧!

问题内容

就我而言,我有数千个 goroutines 同时作为work(). 我也有一个sync()goroutine。启动时sync,我需要任何其他 goroutine 在同步作业完成后暂停一段时间。这是我的代码:

var channels []chan int
var channels_mutex sync.Mutex

func work() {
  channel := make(chan int, 1)
  channels_mutex.Lock()  
  channels = append(channels, channel)
  channels_mutex.Unlock()
  for {
    for {
      sync_stat := 

现在的问题是,由于读取时总是阻塞,所以每次去sync_stat := 都是阻塞的。我知道如果频道关闭它不会被阻止,但是由于我必须使用这个频道直到work()退出,我没有找到任何方法来重新打开一个关闭的频道。

我怀疑自己走错路了,因此感谢您提供任何帮助。是否有一些“优雅”的方式来暂停和恢复任何其他 goroutine?

正确答案

如果我理解正确,您需要 N 个工人和一个控制器,它可以随意暂停、恢复和停止工人。下面的代码将做到这一点。

package main

import (
    "fmt"
    "runtime"
    "sync"
)

// Possible worker states.
const (
    Stopped = 0
    Paused  = 1
    Running = 2
)

// Maximum number of workers.
const WorkerCount = 1000

func main() {
    // Launch workers.
    var wg sync.WaitGroup
    wg.Add(WorkerCount + 1)

    workers := make([]chan int, WorkerCount)
    for i := range workers {
        workers[i] = make(chan int, 1)

        go func(i int) {
            worker(i, workers[i])
            wg.Done()
        }(i)
    }

    // Launch controller routine.
    go func() {
        controller(workers)
        wg.Done()
    }()

    // Wait for all goroutines to finish.
    wg.Wait()
}

func worker(id int, ws 

终于介绍完啦!小伙伴们,这篇关于《是否有一些优雅的方式来暂停和恢复任何其他 goroutine?》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识,快来关注吧!

声明:本文转载于:Golang技术栈 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>