Probleme mit Deadlocks durch Timeout im Ctx verhindern.
This commit is contained in:
parent
6f75f05e06
commit
8b052bc038
|
|
@ -89,11 +89,6 @@ func (f *ElioDateiFoo) ScanCsv(ctx context.Context, data chan<- CountryCsvData)
|
||||||
f.mu.Lock()
|
f.mu.Lock()
|
||||||
f.haveDone[v.filename] = time.Now()
|
f.haveDone[v.filename] = time.Now()
|
||||||
f.mu.Unlock()
|
f.mu.Unlock()
|
||||||
go func() {
|
f.process(ctx, v.filename, data)
|
||||||
//Max 5 Sekunden zum Abarbeiten eines Datensatzes
|
|
||||||
tctx, cancel := context.WithTimeout(ctx, time.Second*5)
|
|
||||||
f.process(tctx, v.filename, data)
|
|
||||||
cancel()
|
|
||||||
}()
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue