// iterator package main // "fmt" // "log" // "strconv" // "time" type produced struct { logins []MongoLogin } func producer() { for loop { wg.Wait() status = _Producer //start := time.Now() // estrae un userid dalla lista degli utenti che hanno fatto login logs := dbs.Mongo.Find(opts.MaxLogins) wg.Add(1) count.AddWG() consume <- produced{ logins: logs, } } done <- true }