1

私は Go が初めてで、「mgo」パッケージを使用して、MongoDB データベース内のすべてのユーザーを反復処理し、ユーザーごとにすべての投稿を反復処理する単純なプログラムを作成しようとしています。

package main

import (
    "fmt"
    "labix.org/v2/mgo"
    "labix.org/v2/mgo/bson"
)

type User struct {
    Id string
    Email string
}

type Post struct {
    Id string
    Description string
}

func handleUser(db *mgo.Database, user *User) {
    fmt.Println("ID: ", user.Id, " EMAIL: ", user.Email)

    result := Post{}

    iter := db.C("posts").Find(bson.M{"user_id": user.Id}).Iter()

    for iter.Next(&result) {
        fmt.Println("POST ID: ", result.Id, " POST DESCRIPTION: ", result.Description)
    }
}

func main() {
    session, err := mgo.Dial("localhost")

    if err != nil {
        panic(err)
    }

    defer session.Close()

    db := session.DB("mydb")

    result := User{}

    iter := db.C("users").Find(nil).Iter()
    for iter.Next(&result) {
        handleUser(db, &result)
    }   
}

handleUser(db, &result)これは問題なく動作していますが、handleUser 内の 2 番目のクエリへの呼び出しを変更しようとしてgo handleUser(db, &result)も何もしません。

「メイン」がすでに終了しているため、セッションはすでに閉じられていると思われますが、正しいですか? もしそうなら、そのようなシナリオを処理する方法は何ですか?

4

1 に答える 1

7

あなたは仕様について正しいです。彼らは、メインが戻ると、すべてのゴルーチンが強制終了されると定義しています:

関数 main が戻ると、プログラムは終了します。他の (メインではない) ゴルーチンが完了するのを待ちません。

2 つのオプションがあります。

  • メインの最後でゴルーチンと同期します。「完了」シャネルまたはsync.WaitGroup.

  • 必要に応じて、空をブロックする select ステートメントを使用できます。

    select{} // Non busy block forever

于 2013-04-15T09:42:03.227 に答える