ブロッキング関数を作成したい node.js

Question

やりたいこと

nodejsでサーバー開発をしています。
その中で、同時に多くの接続があった場合でも、１つずつ処理したい関数があります。
（イメージとしては、同時に多くの接続が来ても、順番に処理したい）

そこで、
execSyncやfs.readFileSyncのようなブロッキング処理を行える関数を自作したい状況です。

promissやasync/awaitでは、そのような制御はできませんでした。

1 ブロッキング処理を実現できるライブラリ
2 そのほかの手法
を探しています。

実装方法をご存じの方いましたら、教えていただきたいです。
よろしくお願いします。

開発環境

node.js v16.5.0

Comments

[hoshi-takanori]

排他制御したいなら async-lock とか使えば良いのでは。
https://neos21.net/blog/2020/07/14-01.html

Answer 1

Webは不特定多数からのリクエストを取り扱う為にわざわざ順不同にしているので
それに逆らうならそれなりの意味があるはずです。
そしてその「逆らう要望」の内容により取るべき手段が変化します。

例えばMySQLのコネクション枯渇問題で排他制御を入れたいのなら
コネクションプールを利用するべきです。

promissやasync/awaitでは、そのような制御はできませんでした。

可能です。

原理としてはpromiseを定義する時
`const promise = new Promise(resolve => {実行内容});
こんな風にresolve関数を定義しますが、これを外部に持ち出す事で
関数の外部でresolveを叩いてpromiseを完了させる事が可能となります。

$ node
Welcome to Node.js v14.17.4.
Type ".help" for more information.

> state = {}
{}

> promise = new Promise(resolve => {state.resolve = resolve})
Promise { <pending> }

> promise
Promise { <pending> }

> state.resolve()
undefined

> promise
Promise { undefined } # <- 終了していることが確認出来る

要は各リクエストを数珠つなぎにしていくだけです。

Promise.resolve(null)
  .then(() => {
    // resolveを外に取り出す
    // 1個目のリクエストを良い感じに完了させる
  })
  .then(() => {
    // resolveを外に取り出す
    // 2個目のリクエストを良い感じに完了させる
  })
  .then(() => {
    // resolveを外に取り出す
    // 3個目のリクエストを良い感じに完了させる
  })

Promiseは後から追加することも可能です。

let promise = Promise.resolve(null);

for (let i = 0; i < 3; i++) {
  promise = promise.then(() => {
    // resolveを外に取り出す
    // i個目のリクエストを良い感じに完了させる。
  })
}

後はresolveの持ち出しと
Promiseの数珠つなぎを駆使して何とか書ききれば出来ます。

この辺は配給の列を準備するラッパーみたいな関数を用意して
これが全部完了したら貴方は動いても良いぞみたいな所までこぎつければ完了ですね。

const express = require("express");

const lineUp = () => {
  // 上記のresolve持ち出しを駆使して取り出す
  return resolve;
}

const app = express();
app.get("/", async (req, res) => {
  // これで後続のリクエストを待たせる
  const resolve = await lineUp();

  // DB等のアクセスで欲しいデータを用意する
  const data = {name: "taro"};

  // resolveを実行してブロッキングを開放
  resolve(); // どんなエラーが発生してもこのresolve関数は実行しておきたい
  res.json(data);
});

ここのコアな部分を作るのはかなり面倒というか、
実装の手間と工数が必要ですし、リクエストが集中した時のメモリリーク対策等
まともに書いてたらキリないですし、責任も取れないのでぼかした感じで終了します。