Python 多线程(while 和 apscheduler)

Question

我试图在 Python 中同时调用两个函数。一种是无限循环，另一种是使用 apscheduler 启动。像这样:

Thread.py

from multiprocessing import Process
import _While
import _Scheduler

if __name__ == '__main__':
    p1 = Process(target=_While.main())
    p1.start()
    p2 = Process(target=_Scheduler.main())
    p2.start()

_While.py

import time


def main():
    while True:
        print "while"
        time.sleep(0.5)

_Scheduler.py

import logging
from apscheduler.scheduler import Scheduler


def _scheduler():
        print "scheduler"


if __name__ == '__main__':
    logging.basicConfig()
    scheduler = Scheduler(standalone=True)
    scheduler.add_interval_job(lambda:  _scheduler(), seconds=2)
    scheduler.start()

由于仅打印了 while ，因此 _Scheduler 似乎尚未启动。 有人可以帮助我吗？

Answer 1

这里至少有几个问题。首先，target 关键字应该是函数，而不是函数的结果。例如:

p1 = Process(target=_While.main)  # Note the lack of function call

其次，我没有看到任何 _Scheduler.main 函数。也许您打算做类似的事情:

import logging
from apscheduler.scheduler import Scheduler


def _scheduler():
        print "scheduler"


def main():
    logging.basicConfig()
    scheduler = Scheduler(standalone=True)
    scheduler.add_interval_job(_scheduler, seconds=2)  # I doubt that `lambda` is necessary here ...
    scheduler.start()

if __name__ == "__main__":
    main()