线程不会 运行 在后台?

Thread won't run in background?

当我调用 my_batch.run_jobs() 时,我的线程不在后台 运行。相反,它通过等待方法完成 运行 同步 运行s。

对于上下文,我从 .py 文件中调用此方法,该方法在 class 中。当我 运行 在此 file/class 之外执行相同的功能时,它 运行 在后台正常运行。

# package_name/module_name.py


class BaseModel(Model):
    class Meta:
        database = get_db()


class Batch(BaseModel):

    def run_jobs():
        
        def sleeper():
            sleep(999)
        
        t = threading.Thread(target=sleeper)
        #t.daemon = True #tried with/ without
        t.start()

例如

my_batch = Batch()
my_batch.run_jobs()
#doesn't print until line above finishes
print("in progress")

我更新了您的代码以进行测试。看来运行符合预期。

import time, threading

class BaseModel(): pass
#    class Meta:
#        database = get_db()

class Batch(BaseModel):

    def run_jobs(self):
        
        def sleeper(): # runs in background thread
            for t in range(10):
               print('<sleeper>', t)
               time.sleep(.9)
        
        t = threading.Thread(target=sleeper)
        t.start()
        
        # this runs same time as background thread (sleeper)
        for t in range(10):
           print('<rj>', t)
           time.sleep(.8)
                
mybatch = Batch()
mybatch.run_jobs()  # runs in main thread

# this loop runs after run_jobs completes
for t in range(5):
   print('<main>', t)
   time.sleep(1)

输出

<sleeper> 0
<rj> 0
<rj> 1
<sleeper> 1
<rj> 2
<sleeper> 2
<rj> 3
<sleeper> 3
<rj> 4
<sleeper> 4
<rj> 5
<sleeper> 5
<rj> 6
<sleeper> 6
<rj> 7
<sleeper> 7
<rj> 8
<rj> 9
<sleeper> 8
<main> 0
<sleeper> 9
<main> 1
<main> 2
<main> 3
<main> 4

---更新---

下面是分成模块的相同代码:

-- mike.py

import time, threading

class BaseModel(): pass
#    class Meta:
#        database = get_db()

class Batch(BaseModel):

    def run_jobs(self):
        
        def sleeper(): # runs in background thread
            for t in range(10):
               print('<sleeper>', t)
               time.sleep(.9)
        
        t = threading.Thread(target=sleeper)
        t.start()
        
        # this runs same time as background thread (sleeper)
        for t in range(10):
           print('<rj>', t)
           time.sleep(.8)

-- threadchk.py(主脚本)

import mike
import time, threading
    
mybatch = mike.Batch()
mybatch.run_jobs()  # runs in main thread

# this loop runs after method completes
for t in range(5):
   print('<main>', t)
   time.sleep(1)

输出与之前相同运行