Go语言协程池模型－－图数据库(Neo4j)写入

Go语言协程池

package main
import (
    "fmt"
    "time"
    driver "github.com/johnnadratowski/golang-neo4j-bolt-driver"
) 
var DriverNeo4j driver.Driver
//写入数据库
func CreateNodes(CypherList []string, Connect driver.Conn){
    if len(CypherList) > 0{
        NilList := make([]map[string]interface{}, len(CypherList))
        stmt, _ := Connect.PreparePipeline(CypherList...)
        _, errexc := stmt.ExecPipeline(NilList...)
        if errexc != nil{
            fmt.Println("excute err!!!!!!!!!!!!",errexc)
        }
        stmt.Close()
    }
}

// 一个job的执行任务
func woker(CypherList chan []string){
    var cypher_str_arr []string
    connect, errcon := DriverNeo4j.OpenNeo("bolt://neo4j:passord@localhost:7687")
    if errcon != nil {
        fmt.Println("connection err!!!!!!!!!", errcon)
    }
    for cypher_str_arr = range CypherList{
        CreateNodes(cypher_str_arr,connect)
    }   
    connect.Close()
    //time.Sleep(1 * time.Second)
}


func main(){
    DriverNeo4j = driver.NewDriver()
    var cypherList []string
    var clearList []string
    var cypherstr string
    jobch := make(chan []string, 10)
    controlch := make(chan int,100)
    for i := 0; i< 70000; i++{
        cypherstr = fmt.Sprintf(`CREATE (n:JJ{Num:%d})`,i)
        cypherList = append(cypherList,cypherstr)
        if len(cypherList) % 20 == 0{
            templist := cypherList
            cypherList = clearList
            jobch <- templist
        }
    }
    //workpool
        //开始用协程池执行各工作
    for w := 0; w < 10; w++{
        go woker(jobch)
    }
    time.Sleep(5 * time.Second)
}