OnlineJudge/submission/tasks.py

# coding=utf-8
from huey.djhuey import task

from judge_dispatcher.tasks import JudgeDispatcher


@task()
def _judge(submission, time_limit, memory_limit, test_case_id, is_waiting_task=False):
    JudgeDispatcher(submission, time_limit, memory_limit, test_case_id).judge(is_waiting_task)
使用 huey 异步队列。 ps 真想自己写一个异步队列，rq 不支持多 worker，celery 太复杂了 2015-12-07 13:19:55 +00:00			`# coding=utf-8`
			`from huey.djhuey import task`

			`from judge_dispatcher.tasks import JudgeDispatcher`


			`@task()`
每次有判题任务完成的时候，递归调用自己判断还有没有等待的任务 2015-12-07 15:20:27 +00:00			`def _judge(submission, time_limit, memory_limit, test_case_id, is_waiting_task=False):`
			`JudgeDispatcher(submission, time_limit, memory_limit, test_case_id).judge(is_waiting_task)`