diff --git a/src/socket.io/topics.js b/src/socket.io/topics.js
index 274950d455..3370db4072 100644
--- a/src/socket.io/topics.js
+++ b/src/socket.io/topics.js
@@ -304,7 +304,7 @@ SocketTopics.moveAll = function(socket, data, callback) {
 				return callback(err);
 			}
 
-			async.each(tids, function(tid, next) {
+			async.eachLimit(tids, 10, function(tid, next) {
 				threadTools.move(tid, data.cid, socket.uid, next);
 			}, callback);
 		});