我已经完成了所有这些步骤。以下是我的程序。我在数据库方面有扎实的知识，但对GOLANG是新手，编写测试程序花费的时间比我项目预定的时间线要多。您能帮我修改代码吗？我想配置5个线程，每个线程并行插入10万条记录，总共插入50万条记录。

package main

import (
    "fmt"
    "gopkg.in/couchbase/gocb.v1"
    "strconv"
    "github.com/zenthangplus/goccm"
    "time"
    "runtime"
)

var  (    
    bucket *gocb.Bucket
)
type Person struct {
	FirstName, LastName string
}

func main(){
    cluster, err := gocb.Connect("couchbase://ip") //Connects to the cluster
    if err != nil {
        fmt.Println(err.Error())
        return
    }
    cluster.Authenticate(gocb.PasswordAuthenticator{
        Username: "",
        Password: "",
    })
    fmt.Println("Cluster:%v",cluster)
        bucket, err = cluster.OpenBucket("", "") //Connects to the bucket
        if err != nil {
            fmt.Println(err.Error())
            return
        }
    fmt.Println("Bucket:%v",bucket)

    // Limit 3 goroutines to run concurrently.
    c := goccm.New(3)
        dt := time.Now()
    fmt.Println("Start Current date and time is: ", dt.String())
    fmt.Println(runtime.NumCPU())
    for i := 1; i <= 500000; i++ {
        fmt.Println("Starting new thread... %v",i )
        person := Person{FirstName: "Syeda", LastName: "Anjum"}
        test := "Go_Demo_"+strconv.Itoa(i)    
        // This function have to call before any goroutine
        c.Wait()
        go createDocument(test, &person)
        fmt.Println("Completed thread... %v",i)
        c.Done()
    }
    fmt.Println(runtime.NumCPU())
    // This function have to call to ensure all goroutines have finished after close the main program.
    c.WaitAllDone()
    fmt.Println("End Current date and time is: ", dt.String())
    fmt.Println(runtime.NumCPU())
} 

func createDocument(documentId string, person *Person) {
	fmt.Println("Upserting a full document...")
	_, error := bucket.Upsert(documentId, person, 0)
	if error != nil {
		fmt.Println(error.Error())
		return
	}
	fmt.Println("After Upsert fetching the document")
}

按照建议修改了我的代码，但在下面这个错误上卡住了。尝试将 j 声明为结构体，但后来无法在 for 操作中使用它。

command-line-arguments

./goprocs.go:54:8: 不能在 send 中使用 j（类型 int）作为 Person 类型

package main

import (
    "fmt"
    "gopkg.in/couchbase/gocb.v1"
)   
    
var  (    
    bucket *gocb.Bucket
)   
type Person struct {
    FirstName, LastName string
}

func main() {
	// if you have more than 5 core, make it 5 to use 5 os thread
	//runtime.GOMAXPROCS(5)
	jobsCount := 50
    cluster, err := gocb.Connect("couchbase://") //Connects to the cluster
    if err != nil {
        fmt.Println(err.Error())
        return
    }
    cluster.Authenticate(gocb.PasswordAuthenticator{
        Username: "",
        Password: "",
    })
    fmt.Println("Cluster:%v",cluster)
        bucket, err = cluster.OpenBucket("", "") //Connects to the bucket
        if err != nil {
            fmt.Println(err.Error())
            return
    }
    fmt.Println("Bucket:%v",bucket)


    person := Person{FirstName: "Syeda", LastName: "Anjum"}
    var jobs []chan Person
    results := make(chan interface{}, jobsCount)

    //jobs := make(chan int, jobsCount)
    //results := make(chan int, jobsCount)

    fmt.Println("value of results: %v",&results)

	for i := 0; i < 5; i++ {
		// create jobs per worker/thread
		workerJobs := make(chan Person, jobsCount)
		jobs = append(jobs, workerJobs)
		go worker(i, workerJobs, results)
	}
	for _, job := range jobs {
		for j:= 1; j <= jobsCount; j++ {
			job <- j
		}
		close(job)
	}
	
	// wait all workers to complete their jobs
	for a := 1; a <= jobsCount*len(jobs); a++ {
		//wait all the workers to return results
		<-results
	}
	fmt.Println("finished")

}
func worker(id int, jobs <-chan Person, results chan<- interface{}) {
	// do your thread measurements here
	fmt.Printf("worker %d started \n", id)
	for person := range jobs {
        createDocument("randomdoc", &person)
		results <- person
	}
	fmt.Printf("worker %d completed \n", id)
}
func createDocument(documentId string, person *Person) {
    fmt.Println("Upserting a full document...")
    _, error := bucket.Upsert(documentId, person, 0)
    if error != nil {
        fmt.Println(error.Error())
        return
    }
    fmt.Println("After Upsert fetching the document")
}