Delayed execution / scheduling with Redis?
Any tricks to do delayed task execution (i.e. scheduling) 开发者_开发知识库based on Redis?
Perhaps some clever way to delay BLPOP for a given number of seconds?..
If you want to do scheduling with redis, i would suggest using sorted set (the z*) commands:
http://code.google.com/p/redis/wiki/SortedSets
what you can do is something like this:
ZADD jobs <unix timestamp of when you want the job to run> <job identifier>
e.g:
ZADD jobs 1291348355
Then, every so often (up to every second) you can pull scheduled jobs that should run (or should have run by now):
ZRANGEBYSCORE jobs -inf, <current unix timestamp>
Boom, you got your jobs to run. Of course, make sure to delete done jobs from the sorted set.
You can work with a ring of multiple LISTs that have a time component in their name. As time component you can take the current second (0-59).
You always add tasks to the list for the current second. To get the jobs you do a BLPOP (with low timeout) only on those lists where it is guaranteed, that the content is older than the given number of seconds.
If you work from multiple hosts you have to take care, that the clocks are in sync (NTP).
While the @efalcao's answer is a very good one, your question might indicate that redis does not perfectly suit your application needs. if your application has the nature of a message box, please consider using rabbitMQ, which features delayed messages or akka if you feel bold
精彩评论