如何使用ants golang调用数据库插入操作

Question

我有一个for循环，它将数据插入到两个不同的表中。在这种情况下，我如何使用ants(下面的包)。

GH包编号：https://github.com/panjf2000/ants

for _, row := range rows {
 user := User{}
 user.Name = row.Name
 user.Email = row.Email
 err := dm.Insert(&user)
 if err != nil {
  panic(err)
 }
 address := Address{}
 address.Address1 = row.Address1
 address.Address2 = row.Address2
 address.PinCode = row.PinCode
 address.City = row.City
 err := dm.Insert(&address)
 if err != nil {
  panic(err)
 }
}

Answer 1

类似于：

func insertRow() {
    // TODO add code to get 'rows'

    const workerCount = 10
    p, err := NewPool(workerCount)
    if err != nil {
        panic(err)
    }

    defer p.Release()

    rowChan := make(chan RowType)

    var wg sync.WaitGroup

    insertRecords := func() {
        defer wg.Done()
   
        row <- rowChan

        user := User{}
        user.Name = row.Name
        user.Email = row.Email
        err := dm.Insert(&user)
        if err != nil {
            panic(err)
        }
        
        address := Address{}
        address.Address1 = row.Address1
        address.Address2 = row.Address2
        address.PinCode = row.PinCode
        address.City = row.City
        err := dm.Insert(&address)
        if err != nil {
            panic(err)
        }
    }

    for _, row := range rows {
        wg.Add(1)
        _ = ants.Submit(insertRecords)
        rowChan <- row
    }

    wg.Wait()
}