线程不会 运行 在后台?
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)
输出与之前相同运行
当我调用 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)
输出与之前相同运行