Diff

util/timer.lua @ 862:b3b80ccddb0c

Merged with main tip.
author Tobias Markmann <tm@ayena.de>
date Tue, 03 Mar 2009 17:48:04 +0100
parent 842:4932f94d35c1
child 896:2c0b9e3c11c3
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/util/timer.lua	Tue Mar 03 17:48:04 2009 +0100
@@ -0,0 +1,51 @@
+-- Prosody IM v0.3
+-- Copyright (C) 2008-2009 Matthew Wild
+-- Copyright (C) 2008-2009 Waqas Hussain
+-- 
+-- This project is MIT/X11 licensed. Please see the
+-- COPYING file in the source package for more information.
+--
+
+
+local ns_addtimer = require "net.server".addtimer;
+local get_time = os.time;
+local t_insert = table.insert;
+local t_remove = table.remove;
+local ipairs, pairs = ipairs, pairs;
+local type = type;
+
+local data = {};
+local new_data = {};
+
+module "timer"
+
+local function _add_task(delay, func)
+	local current_time = get_time();
+	delay = delay + current_time;
+	if delay >= current_time then
+		t_insert(new_data, {delay, func});
+	else func(); end
+end
+
+add_task = _add_task;
+
+ns_addtimer(function()
+	local current_time = get_time();
+	if #new_data > 0 then
+		for _, d in pairs(new_data) do
+			t_insert(data, d);
+		end
+		new_data = {};
+	end
+	
+	for i, d in pairs(data) do
+		local t, func = d[1], d[2];
+		if t <= current_time then
+			data[i] = nil;
+			local r = func();
+			if type(r) == "number" then _add_task(r, func); end
+		end
+	end
+end);
+
+return _M;