summaryrefslogtreecommitdiff
path: root/src/queue/index.ts
diff options
context:
space:
mode:
authorMeiMei <30769358+mei23@users.noreply.github.com>2019-08-27 05:33:24 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2019-08-27 05:33:24 +0900
commit6a0affcec10088ff60ab725f2564e7df7f0eaf17 (patch)
tree6a0bf03478a01702d94dbf420c9a182587471630 /src/queue/index.ts
parent未実装のTLのRenoteクエリを実装 (#5343) (diff)
downloadsharkey-6a0affcec10088ff60ab725f2564e7df7f0eaf17.tar.gz
sharkey-6a0affcec10088ff60ab725f2564e7df7f0eaf17.tar.bz2
sharkey-6a0affcec10088ff60ab725f2564e7df7f0eaf17.zip
Tune worker/job counts (#5346)
* デフォルトのワーカー数を1に * Tune default job count
Diffstat (limited to 'src/queue/index.ts')
-rw-r--r--src/queue/index.ts4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/queue/index.ts b/src/queue/index.ts
index a7e9b9814f..0b20017291 100644
--- a/src/queue/index.ts
+++ b/src/queue/index.ts
@@ -203,8 +203,8 @@ export function createCleanRemoteFilesJob() {
export default function() {
if (!program.onlyServer) {
- deliverQueue.process(128, processDeliver);
- inboxQueue.process(128, processInbox);
+ deliverQueue.process(config.deliverJobConcurrency || 128, processDeliver);
+ inboxQueue.process(config.inboxJobConcurrency || 16, processInbox);
processDb(dbQueue);
procesObjectStorage(objectStorageQueue);
}