Согласно этому документу , мне нужно вставить os.environ["MKL_NUM_THREADS"] = "1"
, чтобы numpy
не использовал более одного ядра.Но куда мне это вставить?до numpy
или в конструкции каждого актера?Должен ли он использоваться в Learner
?
Например, куда мне вставить его, если у меня есть следующие три файла?
""" learner.py """
import numpy as np
import ray
@ray.remote
class Learner:
def __init__(self):
# do something
""" worker.py """
import numpy as np
import ray
@ray.remote
class Worker:
def __init__(self):
# do something
""" main.py """
# program starts from here
import numpy as np
import ray
from learner import Learner
from worker import Worker
ray.init()
learner = Learner.remote()
worker = Worker.remote()
# do something...
Как я могупроверить, работает ли он так, как ожидалось?Вот снимок top
из моего реального проекта, где я вставляю os.environ["MKL_NUM_THREADS"] = "1"
в начале main.py
.Это работает?