node.jsにおいて部分的に非同期処理を同期処理にする方法

Question

以下に記述する順番で処理を実行させたい場合についての質問です
（処理Bは非同期です）

処理A
処理B-1
処理B-2
処理B-3
処理C

調べたところ、
async.seriesで処理Bを囲めば
処理A
処理B群
処理C

となるかなと思ったのですが、

async.seriesのブロックそれ自体が非同期になるので
処理A
処理C
処理B群となってしまいました

処理AもCも含めてasync.seriesで囲めば何とかなりそうですが、
非常に長くて複雑なので、見通しが悪くなってしまうのでそうしたくはありません。

このような場合に、
非同期の処理部分を同期にする方法はありませんでしょうか？

readFileならreadFileSyncを使えばいいですが、
Syncバージョンが用意されていない場合どうしたらいいですか？
というのと似た質問かもしれません。

Answer 1

node.jsのバージョンがv0.12以上であれば、Promiseを利用して簡潔に記述できます。

node -v
# v0.12.7

node task.js
# taskA
# taskA done
# taskB1
# taskB2
# taskB3
# taskB1 done
# taskB2 done
# taskB3 done
# taskC
# taskC done
# all done

// task.js
var taskA= new Promise(function(resolve,reject){
  console.log('taskA')
  setTimeout(function(){
    console.log('taskA done')
    resolve()
  },100)
})

taskA
.then(function(){
  var tasks= []

  var taskB1= new Promise(function(resolve,reject){
    console.log('taskB1')
    setTimeout(function(){
      console.log('taskB1 done')
      resolve()
    },100)
  })
  tasks.push(taskB1)

  var taskB2= new Promise(function(resolve,reject){
    console.log('taskB2')
    setTimeout(function(){
      console.log('taskB2 done')
      resolve()
    },100)
  })
  tasks.push(taskB2);

  var taskB3= new Promise(function(resolve,reject){
    console.log('taskB3')
    setTimeout(function(){
      console.log('taskB3 done')
      resolve()
    },100)
  })
  tasks.push(taskB3);

  return Promise.all(tasks)
})
.then(function(){
  var taskC= new Promise(function(resolve){
    console.log('taskC')
    setTimeout(function(){
      console.log('taskC done')
      resolve()
    },100)
  })

  return taskC
})
.then(function(){
  console.log('all done')
})
.catch(function(reason){
  console.log('fail',reason)
})

Answer 2

さっきのは

• B-1～B-3が長いので全部asyncでくるむのは見通しが悪くなるので避けたい
• B-1～B-3の非同期処理を同期的に処理させる方法が知りたい

という質問の趣旨に合ってなかったようで、すみません

非同期の関数を何とか同期にするということであれば

synchronize.js

とかはどうでしょうか

Comments

[777]

khiroseさん
ご回答ありがとうございます。

async使い慣れていなかったので、
お手本にさせて頂きます。

synchronize.jsを知らなかったので
調べてみます。

結構複雑な処理をしていて、関数を多用しているので
その関数群も含めてasyncで包むというのが大変だなと思っています。

サーバの初期化で、
前回までの結果を読み込んで集計してからサーバ起動。

サービス中にもredisのデータを使って
ユーザに結果を返す。

もう少し設計を見直して、非同期でも動けるようにするのも
手かなとも思い始めました。

Answer 3

async.jsを使うのであれば、async.waterfallとasync.parallelを組み合わせて

async.waterfall([
	function A(done){
		console.log('A');
		done(null);
	},
	function B(done){
		async.parallel([
			function B1(callback){
				console.log('B1');
				callback(null);
			},
			function B2(callback){
				console.log('B2');
				callback(null);
			},
			function B3(callback){
				console.log('B3');
				callback(null);
			},
		], function(err){
			console.log('B1-B3');	
			done(null);
		});
	},
	function C(done){
		console.log('C');
		done(null);
	}
], function(err){
	console.log('ALL Complete.');
});

みたいな形でどうでしょうか

Answer 4

await構文を使ってみてはどうでしょうか。
非同期処理をあたかも同期処理のように扱えます。