监视包含结构的队列中的更改

在多任务处理系统中，监视队列中的变化对于保持队列的准确性和有效性至关重要。当任务添加到队列中时，需要触发相应的清理操作，以删除完成或失败的任务。然而，在实际场景中，添加和清理任务可能无法同时进行，且不能通过直接通信进行协调。本文提供了一种解决方案，通过使用观察者模式在不依赖外部包的情况下监视队列中的变化，并在添加任务后触发清理操作，从而确保队列的完整性。

我有两个 goroutine：

1. 第一个将任务添加到队列
2. 第二个根据状态从队列中清理

添加和清理可能不会同时进行。

如果任务状态为成功，我想从队列中删除该任务，如果不是，我将重试状态为成功（有时间限制）。如果失败，我将记录并从队列中删除。

我们无法在添加和删除之间进行通信，因为这不是现实场景的工作方式。

我想要一个类似观察者的东西，它可以监视队列中的添加并进行以下清理。为了增加复杂性，即使在清理过程中，add 也可能会添加（此处未显示）。我想在不使用外部包的情况下实现它。

我怎样才能实现这个目标？

type Task struct {
    name   string
    status string //completed, failed
}

var list []*Task

func main() {
    done := make(chan bool)
    go Add()
    time.Sleep(15)
    go clean(done)
    <-done
}

func Add() {
    t1 := &Task{"test1", "completed"}
    t2 := &Task{"test2", "failed"}
    list = append(list, t1, t2)
}

func clean() {
    for k, v := range list {
        if v.status == "completed" {
            RemoveIndex(list, k)
        } else {
            //for now consider this as retry
            v.status == "completed"
        }
        if len(list) > 0 {
            clean()
        }
        <-done
    }
}

func RemoveIndex(s []int, index int) []int {
    return append(s[:index], s[index+1:]...)
}

解决方案

所以我找到了一个适合我的解决方案，并将其发布在这里，以供任何可能有帮助的人使用。

在我的主程序中，我添加了一个代码，该代码每 x 秒运行一次，以观察队列中是否添加了某些内容。

type Task struct {
    name   string
    status string //completed, failed
}

var list []*Task

func main() {
    done := make(chan bool)
c := make(chan os.Signal, 2)
    go Add()
    go func() {
        for {
            select {
            // case <-done:
            //  Cleaner(k)
            case <-ticker.C:
                Monitor(done)
            }
        }
    }()
    signal.Notify(c, os.Interrupt, syscall.SIGTERM)
    <-c
    //waiting for interrupt here

}

func Add() {
    t1 := &Task{"test1", "completed"}
    t2 := &Task{"test2", "failed"}
    list = append(list, t1, t2)
}

func Monitor(done chan bool) {
    if len(list) > 0 {
        Cleaner()
    }
}

func cleaner(){
  //do cleaning here
 // pop each element from queue and delete
}

func RemoveIndex(s []int, index int) []int {
    return append(s[:index], s[index+1:]...)
}

所以现在这个解决方案不需要依赖于go例程之间的通信， 在现实场景中，程序永远不会死，并根据用例不断添加和清理。您可以通过在添加到队列和从队列中删除之前锁定和解锁来更好地优化。

到这里，我们也就讲完了《监视包含结构的队列中的更改》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！