node 怎么实现 工作队列？

[mutoudaren]

用 nodejs 简单的搭建了一个 http sever，可以处理 post 请求，执行比如“job1(post)”，“job2(post)”这样的请求，但是这些不同的 job 只能同步执行，也就是一个执行完了再执行另一个。

所以有没有简单的实现，先把 post 请求存到队列里面，然后依次执行？

[opentrade]

类似 WSGI 的东西吧，Python 的比较多，nodejs 的没用过

[dengshen]

rx 。流编程

[beginor]

promise ？

[Rrrrrr]

事件驱动了解一下？

[shiny]

Async.js

[chenqh]

没懂

[streamrx]

async 不就行了

[Sanonz]

https://www.npmjs.com/package/bull

[NemoAlex]

https://github.com/sindresorhus/p-queue

[usw]

桥豆麻袋，“同时执行”和“”产生冲突“具体是啥。async 函数如果没有 await 可咋整

[qping]

web 请求天然就是异步的，想要搞成同步就把消息存在队列里面，然后另外搞个线程处理这个队列

[MegrezZhu]

同时执行产生冲突——那冲突的资源是什么？ CPU ？ IO ？

如果只是想一个个执行的话，post handler 就只接收任务然后加到一个 job queue 里呗，然后自己起一个 worker 一个个拿去执行，这是最 naive 的方法……

[debuggerx]

听描述 应该是客户端 也就是请求端做串行吧
job1 请求拿到返回了再去执行 job2 请求就好了

[lujjjh]

单进程自己写一个没几行代码

https://gist.github.com/lujjjh/ff95a7a046cc271bb06d4fdfb4161197

[muzuiget]

把 job 放到一个包成一个 promise，把这些 promise 放到一个数组里，然后一个个 await 这个数组的元素。

[Exin]

连数组都不需要，最简单的实现如下

```js
let last = Promise.resolve()
onPost(post => last = last.then(() => job(post)))
```

[love]

我自己的小服务程序也是这样。
收到请求，放在内存中请求列表，同时在硬盘上存一份 JSON 请求，然后另一个 async 函数会循环处理请求列表并删除硬盘上的对应文件。当程序重启时会加载硬盘上的所有请求，以免不小心程序各种原因重启时漏掉队列中的请求。

[April5]

bull

[duan602728596]

当初为了实现多文件上传并限制同时上传数，写的一个实现队列的方法，你可以拿去参考参考
https://github.com/duan602728596/Q/blob/main/src/Queue.ts

[zbinlin]

用 async generator 来实现比较简单

//gist.github.com/zbinlin/541ccb9cf6e9c07f98c7605648c7ea34