1

Пишу программу, в которой динамически должны создаваться потоки для вычисления пи. Все созданные потоки должны сбрасывать вычисленное пи в осреднитель.

Как я поняла, существование GIL не даёт по-настоящему параллельно исполнять потоки: один поток захватывает GIL, и пока он не отпустит его, другой поток не будет исполняться.

Как передавать исполнение от одного потока другому? Создаваемые потоки:

class PiThread:
    def __init__(self, piaverager):
        self.thread = Thread(target=self.run)
        self.running = True
        self._result_pi = 0
        self.thread.daemon = True

    def run(self):
        while self.running:
            self._result_pi = # здесь вызов функции вычисления пи
            self.pi_averager.calculate_avg_pi(self._result_pi) # обращение к осредняющему объекту

    def pause(self):
        self.running = False

    def resume(self):
        self.running = True

    def get_name(self):
        return self.thread.getName()

Класс, котролирующий создание/приостановку потоков:

class HeadThread:
    def __init__(self, piaverager):
        self.thread_count = 0
        self.pi = 0
        self.threads = {}
        self.pi_averager = piaverager  # осредняющий объект

    def create_thread(self):
        new_thread = PiThread(self.pi_averager)
        self.threads[new_thread.get_name()] = new_thread
        self.thread_count += 1
        new_thread.thread.start()

    def kill_thread(self, thread_id):
        self.threads[thread_id].pause()
        deleted = self.threads.pop[thread_id]
        self.thread_count -= 1

    def pause_thread(self, thread_id):
        self.threads[thread_id].pause()

    def resume_thread(self, thread_id):
        self.threads[thread_id].resume()

    def get_thread_count(self):
        return self.thread_count

Запускаю:

if __name__ == "__main__":
    pi_averager = PiAverager()
    head_core_thread = HeadThread(pi_averager)
    head_core_thread.create_thread()
    head_core_thread.create_thread()

Судя по тому, что я получаю после запуска, у работы каждого потока есть таймаут, если после обращения к нему есть ещё какие-то операции в коде, иначе -- постоянно работает последний запущенный поток.

Как заставить поток при передаче вычесленного пи в осреднитель, уступать другому потоку? Попробовала добавить 'time.sleep(5.0)', есть ли другие решения?

1 ответ 1

0

Судя по всему time.sleep() это решение.

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.