go - 取消用户特定的 goroutines-6ren

go - 取消用户特定的 goroutines

转载作者：数据小太阳更新时间：2023-10-29 03:40:51

24

4

<分区>

我有一个应用程序(网络应用程序)让用户使用 Twitter oauth 登录并提供自动删除推文的功能。在用户登录到网络应用程序后，我将为每个将删除用户推文列表的用户启动一个 goroutines(通过 REST api)。

假设有 100 个用户，每个用户有 500+ 条推文:

如何在删除过程中停止删除 go 例程。
例如:用户 30 在启动删除过程 2 分钟后请求停止删除推文(这应该通过对我的应用程序的 API 调用来完成)。
在考虑 http 请求和 twitter API 限制的情况下，为了最大限度地提高应用程序的性能，创建 go 例程的最佳做法是什么。我应该为每个用户创建 go 例程还是实现工作池？

信息:我正在使用 anaconda对于 Twitter 客户端后端

编辑:

我找到了一种使用带上下文的 map 来实现它的方法。这是供引用的代码。归功于https://gist.github.com/montanaflynn/020e75c6605dbe2c726e410020a7a974

package main

import (
    "context"
    "fmt"
    "log"
    "net/http"
    "sync"
    "time"
)

// a concurrent safe map type by embedding sync.Mutex
type cancelMap struct {
    sync.Mutex
    internal map[string]context.CancelFunc
}

func newCancelMap() *cancelMap {
    return &cancelMap{
        internal: make(map[string]context.CancelFunc),
    }
}

func (c *cancelMap) Get(key string) (value context.CancelFunc, ok bool) {
    c.Lock()
    result, ok := c.internal[key]
    c.Unlock()
    return result, ok
}

func (c *cancelMap) Set(key string, value context.CancelFunc) {
    c.Lock()
    c.internal[key] = value
    c.Unlock()
}

func (c *cancelMap) Delete(key string) {
    c.Lock()
    delete(c.internal, key)
    c.Unlock()
}

// create global jobs map with cancel function
var jobs = newCancelMap()

// the pretend worker will be wrapped here
// https://siadat.github.io/post/context
func work(ctx context.Context, id string) {

    for {
        select {
        case <-ctx.Done():
            fmt.Printf("Cancelling job id %s\n", id)
            return
        case <-time.After(time.Second):
            fmt.Printf("Doing job id %s\n", id)
        }
    }
}

func startHandler(w http.ResponseWriter, r *http.Request) {

    // get job id and name from query parameters
    id := r.URL.Query().Get("id")

    // check if job already exists in jobs map
    if _, ok := jobs.Get(id); ok {
        fmt.Fprintf(w, "Already started job id: %s\n", id)
        return
    }

    // create new context with cancel for the job
    ctx, cancel := context.WithCancel(context.Background())

    // save it in the global map of jobs
    jobs.Set(id, cancel)

    // actually start running the job
    go work(ctx, id)

    // return 200 with message
    fmt.Fprintf(w, "Job id: %s has been started\n", id)
}

func stopHandler(w http.ResponseWriter, r *http.Request) {

    // get job id and name from query parameters
    id := r.URL.Query().Get("id")

    // check for cancel func from jobs map
    cancel, found := jobs.Get(id)
    if !found {
        fmt.Fprintf(w, "Job id: %s is not running\n", id)
        return
    }

    // cancel the jobs
    cancel()

    // delete job from jobs map
    jobs.Delete(id)

    // return 200 with message
    fmt.Fprintf(w, "Job id: %s has been canceled\n", id)
}

func main() {
    http.HandleFunc("/start", startHandler)
    http.HandleFunc("/stop", stopHandler)
    log.Fatal(http.ListenAndServe(":8080", nil))
}

24

4

0

文章推荐：去教程: Channels and Buffered Channels

文章推荐： c# - 条件异或？

文章推荐： c# - 创建或获取特定的 SPTimeZone 实例

文章推荐： arrays - 在go中删除或调整数组大小

multithreading - Goroutines 是协作调度的。这是否意味着不让出执行的 goroutine 会导致 goroutine 一个一个运行？
发件人:http://blog.nindalf.com/how-goroutines-work/ As the goroutines are scheduled cooperatively, a go
multithreading - 戈朗 : to goroutine or not to goroutine?
很多时候在用 Go 开发 http 服务器时，我都会遇到这种困境。假设我想尽快用http statuscode 200响应客户端(然后在后面执行工作)，这就是我通常这样做的原因: 我让我的主要 ht
go - goroutine 调用行之后的行是否比 goroutine 的第一行更早开始？
这是代码: import "fmt" func main() { messages := make(chan string, 1) go func(c chan string) {
go - 创建 goroutine 并设置最大 goroutines
我正在学习 Golang，但遇到了一些困难。我已经研究过 Google，但没有任何进展。我编写了一个代码，通过多台服务器的 ICMP 检查 RTT。它有这样的结构: type Server str
go - 如何在完成一个 goroutine 后完成所有 goroutine
我想运行多个 goroutine，进行一些处理，将结果放入 channel ，当至少有一个 goroutine 完成时，完成所有其他 goroutine 并从 channel 返回结果。所以，我尝试
go - 如何阻止除正在运行的 goroutines 之外的所有 goroutines
我有两个(但以后我会是三个)go 例程来处理来自远程服务器(来自 ampq channel )的传入消息。但是因为它们正在处理相同的数据/状态，所以我想阻止所有其他 go 例程，除了正在运行的例程。
go - 从 goroutine 获取值并取消另一个 goroutine
我有一个案例，我从 2 个不同的位置(ES 和 REDIS)读取数据，我需要从最快的源读取一个值，因此我触发了 2 个 goroutines，一个从 ES 获取数据，其他从REDIS获取。一旦从其中
go - 如何根据 goroutine 的返回值停止 goroutine
像这里一样，我创建了一个 go playground 示例:sGgxEh40ev ，但无法正常工作。 quit := make(chan bool) res := make(chan int) go
go - 关于 goroutine 在 goroutine 中的行为
我是golang的新手，正在研究goroutine。我写了一个简单的代码，故意使用 goroutine 来划分数字。首先，我给出基数并继续除它的数，直到它不能被整除但是，我改变了go split
go - 如何让多个 goroutine 等待另一个 goroutine 的输出
Main { go routine_1(carryout a time consuming task and return output) go routine_2(wait for output f
go - 从调用另一个 goroutine 的 goroutine 返回
我想知道从另一个 goroutine 返回时调用的 goroutine 会发生什么。他们是继续运行还是被终止？这是一个示例代码来说明我的意思: func func() { // Doing s
go - 一个 goroutine 从结构中读取而另一个 goroutine 正在修改它是否安全？
更具体地说，在我的例子中，我有一个网络服务器和一个全局可访问的结构，网络服务器使用它来生成页面。我有另一个 Goroutine，它总是定期用新值更新该结构。这会引起问题吗？我是否需要实现一种机制来确保
go - 从另一个 goroutine 启动一个 goroutine 是什么意思？
来自 this file ，我不明白为什么函数startWorker会这样写: func (p *WorkerPool) dispatch() { for i := 0; i < p.maxW
go - 无法无限期地写入一个 goroutine 并从另一个 goroutine 中读取
我正在学习围棋，但在使用 goroutines 时遇到了问题。这是我的代码 package main import ( "fmt" "sync" "time" ) var co
go - 反正执行 goroutine 时所有 goroutines 都睡着了
我收到以下错误，我不明白为什么: 发送:查询 Herefatal 错误:所有 goroutines 都睡着了 - 死锁! 您可以看到我正在调用我使用 goroutine 创建的函数 routine。我
go - 我如何等待对多个其他 Goroutines 的单个 Goroutine 响应？
大家好，我正在从 Python3 过渡到 Go，所以我正在尝试重写我创建的库以获得更好的性能。我面临一个问题，因为我是 Golang XD 中的新手，我使用有限的 API 下载数百个 json，我想
go - 用 goroutines 调用非 goroutine 函数
我有以下格式的脚本部分: func main() { for i=0;i<1000000;i++ { go test() } } func test() { a := test
go - 在同一个 goroutines 中创建的 goroutines 是否总是按顺序执行？
package main func main() { c:=make(chan int) for i:=0; i<=100;i++ {
go - 在 goroutines 中启动 goroutines 是否可以接受？
我正在学习 Go，我的第一个项目是一个简单的 ping 脚本。本质上，我想 ping 一堆 url，并在每个响应时等待 XXX 秒，然后再次 ping。这是删减的代码: func mai
algorithm - 程序正在等待 goroutines 完成，但 goroutines 被死锁
这个问题在这里已经有了答案: Go all goroutines are asleep deadlock (2 个回答) fatal error: all goroutines are asleep

首页

博学

6Ren·AI

商城

go - 取消用户特定的 goroutines