我正在使用我當前的項目，我遇到了一些文檔中沒有的情況。gocron我測試這個代碼：gocron.Every(3).Seconds().Do(taskWithParams,2,"world")gocron.Every(2).Seconds().Do(taskWithParams,1, "hello")gocron.Start()time.Sleep(10 * time.Second)gocron.Remove(taskWithParams)//<-- remove task...func taskWithParams(a int, b string) { fmt.Println(a, b)}當我刪除 task（） 時，總是被刪除。即使我交換它們：gocron.Remove(taskWithParams)gocron.Every(3).Seconds().Do(taskWithParams,2,"world")gocron.Every(2).Seconds().Do(taskWithParams,1, "hello")gocron.Every(3).Seconds().Do(taskWithParams,2,"world")有沒有辦法讓我具體指出我要刪除的任務，因為唯一允許1？remove()argument該文檔還有一個：schedulers := gocron.NewScheduler() s.Every(3).Seconds().Do(task) <- s.Start()什么時候是最好的用例？scheduler如果我們完成了調度程序，如何將其從內存中刪除？做工作嗎？或者我們必須有另一種方法將它們從記憶中清除？scheduler.Clear()
1 回答
函數式編程
TA貢獻1807條經驗 獲得超9個贊
您可以通過對函數處理程序進行重復數據刪除來處理刪除邏輯。
package main
import (
"fmt"
)
func main() {
fn1 := func() { taskWithParams(2, "world") }
gocron.Every(3).Seconds().Do(fn1)
fn2 := func() { taskWithParams(1, "hello") }
gocron.Every(2).Seconds().Do(fn2)
gocron.Start()
time.Sleep(10 * time.Second)
gocron.Remove(fn2)
}
func taskWithParams(a int, b string) {
fmt.Println(a, b)
}
否則，該方法將返回一個可以傳遞給 的實例。scheduler.Do*Jobscheduler.RemoveByReference
package main
import (
"fmt"
)
func main() {
job, err := gocron.Every(3).Seconds().Do(taskWithParams, 2, "ww")
if err != nil {
panic(err)
}
gocron.Every(2).Seconds().Do(taskWithParams, 1, "hh")
gocron.Start()
time.Sleep(10 * time.Second)
gocron.RemoveByReference(job)
}
func taskWithParams(a int, b string) {
fmt.Println(a, b)
}
- 1 回答
- 0 關注
- 425 瀏覽
添加回答
舉報
0/150
提交
取消