diff options
author | 2018-11-11 15:32:48 -0800 | |
---|---|---|
committer | 2018-11-11 15:32:48 -0800 | |
commit | 487852f07eb191ef56967b7b7d7f01537a55eabd (patch) | |
tree | 0c5194c4371392128917a0860ac7a6b00f7784a2 /scheduler/worker_pool.go | |
parent | ca45765c46de3b00c3b22936c885b57c37186e3d (diff) |
Replace daemon and scheduler package with service package
Diffstat (limited to 'scheduler/worker_pool.go')
-rw-r--r-- | scheduler/worker_pool.go | 36 |
1 files changed, 0 insertions, 36 deletions
diff --git a/scheduler/worker_pool.go b/scheduler/worker_pool.go deleted file mode 100644 index ce5a453..0000000 --- a/scheduler/worker_pool.go +++ /dev/null @@ -1,36 +0,0 @@ -// Copyright 2017 Frédéric Guillot. All rights reserved. -// Use of this source code is governed by the Apache 2.0 -// license that can be found in the LICENSE file. - -package scheduler // import "miniflux.app/scheduler" - -import ( - "miniflux.app/model" - "miniflux.app/reader/feed" -) - -// WorkerPool handle a pool of workers. -type WorkerPool struct { - queue chan model.Job -} - -// Push send a list of jobs to the queue. -func (w *WorkerPool) Push(jobs model.JobList) { - for _, job := range jobs { - w.queue <- job - } -} - -// NewWorkerPool creates a pool of background workers. -func NewWorkerPool(feedHandler *feed.Handler, nbWorkers int) *WorkerPool { - workerPool := &WorkerPool{ - queue: make(chan model.Job), - } - - for i := 0; i < nbWorkers; i++ { - worker := &Worker{id: i, feedHandler: feedHandler} - go worker.Run(workerPool.queue) - } - - return workerPool -} |