OnlineJudge/submission/tasks.py

# coding=utf-8
from __future__ import absolute_import
from celery import shared_task
from judge_dispatcher.tasks import JudgeDispatcher


@shared_task
def _judge(submission_id, time_limit, memory_limit, test_case_id, spj=False, spj_language=None, spj_code=None, spj_version=None):
    JudgeDispatcher(submission_id, time_limit, memory_limit, test_case_id, spj, spj_language, spj_code, spj_version).judge()
使用 huey 异步队列。 ps 真想自己写一个异步队列，rq 不支持多 worker，celery 太复杂了 2015-12-07 13:19:55 +00:00			`# coding=utf-8`
废弃 huey，多数据库连接的时候存在 connection 无法释放的问题，回到 celery 2015-12-12 07:41:57 +00:00			`from __future__ import absolute_import`
			`from celery import shared_task`
使用 huey 异步队列。 ps 真想自己写一个异步队列，rq 不支持多 worker，celery 太复杂了 2015-12-07 13:19:55 +00:00			`from judge_dispatcher.tasks import JudgeDispatcher`


废弃 huey，多数据库连接的时候存在 connection 无法释放的问题，回到 celery 2015-12-12 07:41:57 +00:00			`@shared_task`
完成对SPJ的支持 xml rpc不能使用None 2016-04-06 12:33:19 +00:00			`def _judge(submission_id, time_limit, memory_limit, test_case_id, spj=False, spj_language=None, spj_code=None, spj_version=None):`
			`JudgeDispatcher(submission_id, time_limit, memory_limit, test_case_id, spj, spj_language, spj_code, spj_version).judge()`