为什么我在main中使用goroutine时我的程序没有关闭？

Question

语境

请仔细阅读代码中的注释。一切都在他们身上。

如果您有使用经验discordgo

完整的代码可以在这里找到：https ://github.com/telephrag/kubinka/tree/bug （查看包strg和main）添加 goroutine 命令处理程序也会停止正常工作。与数据库交互相关的所有内容（分别在 /deploy 和 /return 上存储和从数据库中删除）根本不起作用。用户只会收到“应用程序未响应”消息而不是正确的响应（请参阅以cmd_前缀开头的包）。

package main

import (

    "context"

    "fmt"

    "log"

    "os"

    "os/signal"

    "syscall"

    "time"

    "go.etcd.io/bbolt"

)

/*  TO REPRODUCE:

Start the program wait a few seconds and press ^C.

Expect the case of program not shutting down after few attempts.

*/

func WatchExpirations(ctx context.Context, db *bbolt.DB, bkt string) error {

    timeout := time.After(time.Second * 5)

    for {

        select {

        case <-timeout:

            tx, err := db.Begin(true)

            if err != nil {

                return fmt.Errorf("bolt: failed to start transaction")

            }

            bkt := tx.Bucket([]byte(bkt))

            c := bkt.Cursor()

            for k, v := c.First(); k != nil; k, v = c.Next() {

                // do stuff with bucket...

                fmt.Println(v) // check if v matches condition, delete if does

                if err := tx.Commit(); err != nil { // BUG: commiting transaction in a loop

                    tx.Rollback()

                    return fmt.Errorf("bolt: failed to commit transaction: %w", err)

                }

                timeout = time.After(time.Second * 5)

            }

        case <-ctx.Done():

            return ctx.Err()

        }

    }

}

func main() {

    ctx, cancel := context.WithCancel(context.Background())

    db, err := bbolt.Open("kubinka.db", 0666, nil)

    if err != nil {

        log.Panicf("failed to open db %s: %v", "kubinka.db", err)

    }

    if err = db.Update(func(tx *bbolt.Tx) error {

        _, err := tx.CreateBucketIfNotExists([]byte("players"))

        if err != nil {

            return fmt.Errorf("failed to create bucket %s: %w", "players", err)

        }

        return nil

    }); err != nil {

        log.Panic(err)

    }

Answer 1

根据您的回购协议中的评论，问题似乎出在这里：tx, err := db.Begin(true)if err != nil {&nbsp; &nbsp;return fmt.Errorf("bolt: failed to start transaction")}bkt := tx.Bucket([]byte(bkt))c := bkt.Cursor()for k, v := c.First(); k != nil; k, v = c.Next() {&nbsp; &nbsp; // do stuff with bucket...&nbsp; &nbsp; fmt.Println(v) // check if v matches condition, delete if does&nbsp; &nbsp; if err := tx.Commit(); err != nil { // BUG: commiting transaction in a loop&nbsp; &nbsp; &nbsp; &nbsp; tx.Rollback()&nbsp; &nbsp; &nbsp; &nbsp; return fmt.Errorf("bolt: failed to commit transaction: %w", err)&nbsp; &nbsp; }&nbsp; &nbsp; timeout = time.After(time.Second * 5)}循环可以迭代 0 次。如果没有迭代 -tx不提交timeout也不重置（因此case <-timeout:不会再次触发）。如果有多次迭代 - 您将尝试tx.Commit()多次（错误）。这可能导致了您看到的问题；bolt&nbsp;Close功能：_关闭释放所有数据库资源。在关闭数据库之前必须关闭所有事务。因此，如果有一个事务运行Close块直到完成（内部螺栓在事务开始时锁定互斥锁并在完成时释放它）。解决方案是确保事务始终关闭（并且只关闭一次）。