Node.jsでfor文を使うには

Question

 rooms=new Array;

  socket.on("join",function(msg){//Connect
          rooms.push(socket.id);
                for(var i=0;i<rooms.length;i++){
                 //ここでroomsの一斉操作がしたい
          //joinが呼び出されてから○○分反応が無いidは削除する。。等
                }
   }

Node.jsのSocket.ioで上記のような配列を扱っているのですが、上記のfor文は並列処理な為、rooms[i]等とした場合、予期しない現象が起きてしまいます。これを解決させるにはどうしたらいいのでしょうか。アドバイスお願いいたします。

Answer 1

上記のfor文は並列処理な為、rooms[i]等とした場合、予期しない現象が起きてしまいます。

自分には質問者さんが「並列処理」であることが「複数の関数が同時に並行して実行されてしまう」と考えておられるように見えました。マルチスレッドが可能な言語システム上(例えばC,C++,Java,C#,Ruby,Pythonなどなど)で異なるスレッドが並行動作している場合にはおっしゃるとおり複数の関数が「同時に並行して動作する」というのは正しいです。しかしながらNodejsでは並列処理をシングルスレッドで実行する方式のため、複数の関数が同時に並行して動くことはありません。

例がイマイチよくないですが、実験のため次のようなコードを考えてみました(長ったらしくて申し訳ないです)。この例ではusersという配列を非同期に発生するイベント'join'と'say'の2つのコールバックの中で「更新」と「参照」をしています。しかしこのように書いても'join'と'say'のコールバックは同時に動くことはないので'join'のコールバックの中でusers変数の破壊的更新を行っても問題ありません。あるイベントが発生するとNodejsのランタイムからそのイベントのコールバックが起動されるのですが、そのコールバック関数の実行中に例え他のイベントが発生しても関数の実行が完了するまでは次のイベントの起動は待たされるのです。

const users = [],
      TIMEOUT = 5 * 1000,
      START = +new Date(),
      pe = new PsudoEventEmitter();
let id_counter = 0;

//---------------------------------------
// 0.1 - 5.0 sec間隔で新規ユーザーがjoin
//---------------------------------------
pe.on('join', 100, 5000,
  function () {
    const now = +new Date(),
          user = {
            id: ++id_counter,
            access_time: +new Date()
          };
    users.push(user);
    console.log(elapsed(now) + ": joined " + user['id']);
    // join後5秒以上発言のないユーザーを削除
    for (let i = 0; i < users.length; i++) {
      let user = users[i];
      if (now - user['access_time'] > TIMEOUT) {
        console.log(elapsed(now) + ":   removed " + user['id']);
        users.splice(i, 1);  // usersからi番目の要素を削除
        --i;
      }
    }
  });

//---------------------------------------
// 0.1 - 1.0 sec間隔で誰かが発言
//---------------------------------------
pe.on('say', 100, 1000,
  function () {
    if (users.length == 0)
      return;
    const now = +new Date(),
          index = Math.floor(Math.random() * users.length),
          user = users[index];
    user['access_time'] = now;
    console.log(elapsed(now) + ": say hi from " + user['id']);
  });

function elapsed(now) {
  let e = Math.floor((now - START) / 1000);
  return e;
}

//-------------------------------------------
// randomにイベントを発生させるためのutility
//-------------------------------------------
function PsudoEventEmitter() {
  let events = {};

  function on(name, min, max, cb) {
    const event = { name: name, min: min, max: max, cb: cb };
    events[name] = event;
    register(name);
  }

  function register(name) {
    const ev = events[name];
    setTimeout(
      function () { fire(name) },
      rand(ev.min, ev.max));
  }

  function fire(name) {
    const ev = events[name];
    ev['cb']();
    register(name);
  }

  function rand(low, high) {
    return low + Math.random() * (high - low);
  }

  PsudoEventEmitter.prototype.on = on;
}