线程不会在后台运行？

Question

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

对于上下文，我从.py文件中调用此方法，并且该方法在类中。当我在这个文件/类之外运行相同的函数时，它会在后台正常运行

# 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")

Answer 1

我更新了你的测试代码。它似乎按预期运行

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

-更新-

以下是相同的代码，分为模块：

迈克·皮

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)

输出与上一次运行相同