Add parallel write

main.go

@@ -87,6 +87,24 @@ func main() {
 	existingVids := queryItems(conn)
 	fmt.Println("Items queried")
 	cnt := 100000
+	fmt.Println("Running writer")
+	go func() {
+		conn := GetTTConnn(os.Args[1])
+		fchan := make(chan *tarantool.Future, 100000)
+		go func() {
+			for {
+				fchan <- conn.InsertAsync("visitorid_matching", []interface{}{"host1", "host2", newVid(), newVid()})
+				time.Sleep(time.Microsecond* 100)
+			}
+			close(fchan)
+		}()
+		for f := range fchan {
+			_, err := f.Get()
+			if err != nil {
+				log.Fatal(err)
+			}
+		}
+	}()
 	fmt.Println("Item count",cnt)
 	items := genItems(existingVids, cnt)
 	for _, item := range items {