diff --git a/async.lua b/async.lua
index c618df5..7ff539a 100644
--- a/async.lua
+++ b/async.lua
@@ -1,79 +1,58 @@
 function extended_api.Async()
 	local self = {}
 	
-	self.pool = {threads = {}, globalstep_threads = {}, task_queue = {}, resting = 200, maxtime = 200, queue_threads = 8, state = "suspended"}
+	self.task_queue = {}
+	self.resting = 200
+	self.maxtime = 200
+	self.queue_threads = 8
+	self.state = "suspended"
 	
 	self.create_worker = function(func)
 		local thread = coroutine.create(func)
 		if not thread or coroutine.status(thread) == "dead" then
 			minetest.after(0.3, self.create_worker, func)
-			minetest.after(0.5, self.schedule_worker)
-			minetest.chat_send_all("Fall")
 			return
 		end
-		table.insert(self.pool.threads, thread)
+		self.run_worker(thread)
 	end
 	
 	self.create_globalstep_worker = function(func)
 		local thread = coroutine.create(func)
 		if not thread or coroutine.status(thread) == "dead" then
 			minetest.after(0.3, self.create_globalstep_worker, func)
-			minetest.after(0.5, self.schedule_globalstep_worker)
 			return
 		end
-		table.insert(self.pool.globalstep_threads, thread)
+		self.run_globalstep_worker(thread)
 	end
-	self.run_worker = function(index)
-		local thread = self.pool.threads[index]
+	self.run_worker = function(thread)
 		if not thread or coroutine.status(thread) == "dead" then
-			table.remove(self.pool.threads, index)
 			return false
 		else
 			coroutine.resume(thread)
-			minetest.after(0, self.schedule_worker)
+			minetest.after(self.resting / 1000, self.run_worker, thread)
 			return true
 		end
 	end
 
-	self.run_globalstep_worker = function(index)
-		local thread = self.pool.globalstep_threads[index]
+	self.run_globalstep_worker = function(thread)
 		if not thread or coroutine.status(thread) == "dead" then
-			table.remove(self.pool.globalstep_threads, index)
 			return false
 		else
 			coroutine.resume(thread)
-			minetest.after(0, self.schedule_globalstep_worker)
+			minetest.after(0, self.run_globalstep_worker, thread)
 			return true
 		end
 	end
 
-	self.schedule_worker = function()
-		self.pool.state = "running"
-		for index, value in ipairs(self.pool.threads) do
-			minetest.after(self.pool.resting / 1000, self.run_worker, index)
-			return true
-		end
-		self.pool.state = "suspended"
-		return false
-	end
-
-	self.schedule_globalstep_worker = function()
-		for index, value in ipairs(self.pool.globalstep_threads) do
-			minetest.after(0, self.run_globalstep_worker, index)
-			return true
-		end
-		return false
-	end
-
 	self.priority = function(resting, maxtime)
-		self.pool.resting = resting
-		self.pool.maxtime = maxtime
+		self.resting = resting
+		self.maxtime = maxtime
 	end
 
 	self.iterate = function(from, to, func, callback)
 		self.create_worker(function()
 			local last_time = minetest.get_us_time() / 1000
-			local maxtime = self.pool.maxtime
+			local maxtime = self.maxtime
 			for i = from, to do
 				local b = func(i)
 				if b ~= nil and b == false then
@@ -89,15 +68,14 @@ function extended_api.Async()
 			end
 			return
 		end)
-		self.schedule_worker()
 	end
 
 	self.foreach = function(array, func, callback)
 		self.create_worker(function()
 			local last_time = minetest.get_us_time() / 1000
-			local maxtime = self.pool.maxtime
+			local maxtime = self.maxtime
 			for k,v in ipairs(array) do
-				local b = func(k, v)
+				local b = func(k,v)
 				if b ~= nil and b == false then
 					break
 				end
@@ -111,13 +89,12 @@ function extended_api.Async()
 			end
 			return
 		end)
-		self.schedule_worker()
 	end
 
 	self.do_while = function(condition_func, func, callback)
 		self.create_worker(function()
 			local last_time = minetest.get_us_time() / 1000
-			local maxtime = self.pool.maxtime
+			local maxtime = self.maxtime
 			while(condition_func()) do
 				local c = func()
 				if c ~= nil and c ~= condition_func() then
@@ -133,7 +110,6 @@ function extended_api.Async()
 			end
 			return
 		end)
-		self.schedule_worker()
 	end
 
 	self.register_globalstep = function(func)
@@ -150,14 +126,13 @@ function extended_api.Async()
 				end
 			end
 		end)
-		self.schedule_globalstep_worker()
 	end
 
 	self.chain_task = function(tasks, callback)
 		self.create_worker(function()
 			local pass_arg = nil
 			local last_time = minetest.get_us_time() / 1000
-			local maxtime = self.pool.maxtime
+			local maxtime = self.maxtime
 			for index, task_func in pairs(tasks) do
 				local p = task_func(pass_arg)
 				if p ~= nil then
@@ -173,20 +148,19 @@ function extended_api.Async()
 			end
 			return
 		end)
-		self.schedule_worker()
 	end
 
 	self.queue_task = function(func, callback)
-		table.insert(self.pool.task_queue, {func = func,callback = callback})
-		if self.pool.queue_threads > 0 then
-			self.pool.queue_threads = self.pool.queue_threads - 1
+		table.insert(self.task_queue, {func = func,callback = callback})
+		if self.queue_threads > 0 then
+			self.queue_threads = self.queue_threads - 1
 			self.create_worker(function()
 				local pass_arg = nil
 				local last_time = minetest.get_us_time() / 1000
-				local maxtime = self.pool.maxtime
+				local maxtime = self.maxtime
 				while(true) do
-					local task_func = self.pool.task_queue[1]
-					table.remove(self.pool.task_queue, 1)
+					local task_func = self.task_queue[1]
+					table.remove(self.task_queue, 1)
 					if task_func and task_func.func then
 						pass_arg = nil
 						local p = task_func.func()
@@ -201,12 +175,11 @@ function extended_api.Async()
 							last_time = minetest.get_us_time() / 1000
 						end
 					else
-						self.pool.queue_threads = self.pool.queue_threads + 1
+						self.queue_threads = self.queue_threads + 1
 						return
 					end
 				end
 			end)
-			self.schedule_worker()
 		end
 	end
 
@@ -221,7 +194,6 @@ function extended_api.Async()
 			end
 			return
 		end)
-		self.schedule_worker()
 	end
 	return self
 end