obitools/obitools4
2
0
Fork 0
mirror of https://github.com/metabarcoding/obitools4.git synced 2025-06-29 16:20:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add information on the number of workers in the log

Browse Source
This commit is contained in:
Eric Coissac
2022-08-21 13:41:58 +02:00
parent f00456fcf3
commit 844e24b818
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/obiiter/workers.go
View File

@ -19,8 +19,6 @@ func AnnotatorToSeqWorker(function SeqAnnotator) SeqWorker {
return f return f
} }
func (iterator IBioSequenceBatch) MakeIWorker(worker SeqWorker, sizes ...int) IBioSequenceBatch { func (iterator IBioSequenceBatch) MakeIWorker(worker SeqWorker, sizes ...int) IBioSequenceBatch {
nworkers := 4 nworkers := 4
buffsize := iterator.BufferSize() buffsize := iterator.BufferSize()
@ -93,7 +91,7 @@ func (iterator IBioSequenceBatch) MakeISliceWorker(worker SeqSliceWorker, sizes
newIter.Done() newIter.Done()
} }
log.Println("Start of the batch slice workers") log.Printf("Start of the batch slice workers on %d workers (buffer : %d)\n", nworkers, buffsize)
for i := 0; i < nworkers-1; i++ { for i := 0; i < nworkers-1; i++ {
go f(iterator.Split()) go f(iterator.Split())
} }
@ -102,7 +100,6 @@ func (iterator IBioSequenceBatch) MakeISliceWorker(worker SeqSliceWorker, sizes
return newIter return newIter
} }
func (iterator IBioSequence) MakeIWorker(worker SeqWorker, sizes ...int) IBioSequence { func (iterator IBioSequence) MakeIWorker(worker SeqWorker, sizes ...int) IBioSequence {
buffsize := iterator.BufferSize() buffsize := iterator.BufferSize()
@ -133,7 +130,7 @@ func (iterator IBioSequence) MakeIWorker(worker SeqWorker, sizes ...int) IBioSeq
func WorkerPipe(worker SeqWorker, sizes ...int) Pipeable { func WorkerPipe(worker SeqWorker, sizes ...int) Pipeable {
f := func(iterator IBioSequenceBatch) IBioSequenceBatch { f := func(iterator IBioSequenceBatch) IBioSequenceBatch {
return iterator.MakeIWorker(worker,sizes...) return iterator.MakeIWorker(worker, sizes...)
} }
return f return f
@ -141,7 +138,7 @@ func WorkerPipe(worker SeqWorker, sizes ...int) Pipeable {
func SliceWorkerPipe(worker SeqSliceWorker, sizes ...int) Pipeable { func SliceWorkerPipe(worker SeqSliceWorker, sizes ...int) Pipeable {
f := func(iterator IBioSequenceBatch) IBioSequenceBatch { f := func(iterator IBioSequenceBatch) IBioSequenceBatch {
return iterator.MakeISliceWorker(worker,sizes...) return iterator.MakeISliceWorker(worker, sizes...)
} }
return f return f