加载中…
个人资料
微博
  • 博客等级：
  • 博客积分：
  • 博客访问：
  • 关注人气：
  • 获赠金笔：0支
  • 赠出金笔：0支
  • 荣誉徽章：
正文 字体大小：大 中 小

Nodejs中Error：EMFILE，toomanyopenfiles的解决方案

(2021-04-05 22:34:39)
分类： htmlcssjsnodejs
https://github.com/freewind/async_demo/blob/master/queue.js

var t = require('./t');
var log = t.log;

// queue(worker, concurrency)

// 定义一个queue，设worker数量为2
var q = async.queue(function(task, callback) {
log('worker is processing task: ', task.name);
task.run(callback);
}, 2);

// 如果某次push操作后，任务数将达到或超过worker数量时，将调用该函数
q.saturated = function() {
log('all workers to be used');
}

// 当最后一个任务交给worker时，将调用该函数
q.empty = function() {
log('no more tasks wating');
}

// 当所有任务都执行完以后，将调用该函数
q.drain = function() {
console.log('all tasks have been processed');
}

// 放入单个任务
q.push({name:'t1', run: function(cb){
log('t1 is running, waiting tasks: ', q.length());
t.fire('t1', cb, 400); // 400ms后执行
}}, function(err) {
log('t1 executed');
});

log('pushed t1, waiting tasks: ', q.length());

q.push({name:'t2',run: function(cb){
log('t2 is running, waiting tasks: ', q.length());
t.fire('t2', cb, 200); // 200ms后执行
}}, function(err) {
log('t2 executed');
});

log('pushed t2, waiting tasks: ', q.length());

// 放入多个任务
q.push([{name:'t3', run: function(cb){
log('t3 is running, waiting tasks: ', q.length());
t.fire('t3', cb, 300); // 300ms后执行
}},{name:'t4', run: function(cb){
log('t4 is running, waiting tasks: ', q.length());
t.fire('t4', cb, 500); // 500ms后执行
}}], function(err) {
log('t3/4 executed');
});

log('pushed t3/t4, waiting tasks: ', q.length());
var async = require('async');

喜欢

0

阅读┊ 收藏 ┊ 喜欢▼ ┊打印┊举报/Report
  

新浪BLOG意见反馈留言板　欢迎批评指正

新浪简介 | About Sina | 广告服务 | 联系我们 | 招聘信息 | 网站律师 | SINA English | 产品答疑

Copyright © 1996 - 2022 SINA Corporation, All Rights Reserved

新浪公司 版权所有