如何同时执行两个任务

Question

我正在与我遇到问题的芹菜一起工作。

我有两个功能：1(当该程序激活时将激活此功能，并且它将无限地工作：

from celery.signals import worker_ready    
@worker_ready.connect()
def message_poll_start(sender=None, headers=None, body=None, **kwargs):
    while True:
        time.sleep(2)
        print("hello")

2(此功能将每隔十秒激活一次，并在txt文件中写下日期：

@periodic_task(run_every=timedelta(seconds=10))
def last_record_time_check():
    file_text = open('file.txt', 'a')
    file_text.write("===========" + str(datetime.datetime.now()) +
                    " =============== nn")

最后我使用了芹菜和芹菜

第一个功能无问题，但第二个功能根本不起作用。

[2018-02-06 16:43:17,802: INFO/MainProcess] beat: Starting...
[2018-02-06 16:43:27,947: INFO/MainProcess] Scheduler: Sending due task base.tasks.last_record_time_check (base.tasks.last_record_time_check)
[2018-02-06 16:43:37,925: INFO/MainProcess] Scheduler: Sending due task base.tasks.last_record_time_check (base.tasks.last_record_time_check)
[2018-02-06 16:43:47,926: INFO/MainProcess] Scheduler: Sending due task base.tasks.last_record_time_check (base.tasks.last_record_time_check)

Answer 1

看起来您的函数被卡在第一个函数上，因为它总是在循环中。