2

Я изучаю многопроцессность, многопоточность и асинхронность в питоне. Я написал вот такой простой код для практики:

import time
import tkinter as tk
import multiprocessing as mp

def start():
    process = mp.Process(target=lambda: time.sleep(2))
    
    print("begin")
    
    process.run()
    
    print("end")

def main():
    root = tk.Tk()
    
    tk.Button(root, text="Button", command=start).pack()
    
    tk.mainloop()

if __name__ == "__main__":
    main()

Но я получаю вот такую странную ошибку:

begin
Exception in Tkinter callback
Traceback (most recent call last):
  File "C:\Users\egork\AppData\Local\Programs\Python\Python311\Lib\tkinter\__init__.py", line 1948, in __call__
    return self.func(*args)
           ^^^^^^^^^^^^^^^^
  File "c:\Users\egork\OneDrive\\u0420\u0430\u0431\u043e\u0447\u0438\u0439 \u0441\u0442\u043e\u043b\\u041f\u0440\u043e\u0435\u043a\u0442\u044b Python\testing\index.py", line 10, in start
    process.start()
  File "C:\Users\egork\AppData\Local\Programs\Python\Python311\Lib\multiprocessing\process.py", line 121, in start
    self._popen = self._Popen(self)
                  ^^^^^^^^^^^^^^^^^
  File "C:\Users\egork\AppData\Local\Programs\Python\Python311\Lib\multiprocessing\context.py", line 224, in _Popen
    return _default_context.get_context().Process._Popen(process_obj)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\egork\AppData\Local\Programs\Python\Python311\Lib\multiprocessing\context.py", line 336, in _Popen
    return Popen(process_obj)
           ^^^^^^^^^^^^^^^^^^
  File "C:\Users\egork\AppData\Local\Programs\Python\Python311\Lib\multiprocessing\popen_spawn_win32.py", line 95, in __init__
    reduction.dump(process_obj, to_child)
  File "C:\Users\egork\AppData\Local\Programs\Python\Python311\Lib\multiprocessing\reduction.py", line 60, in dump
    ForkingPickler(file, protocol).dump(obj)
AttributeError: Can't pickle local object 'start.<locals>.<lambda>'
Traceback (most recent call last):
  File "<string>", line 1, in <module>
  File "C:\Users\egork\AppData\Local\Programs\Python\Python311\Lib\multiprocessing\spawn.py", line 122, in spawn_main
    exitcode = _main(fd, parent_sentinel)
               ^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\egork\AppData\Local\Programs\Python\Python311\Lib\multiprocessing\spawn.py", line 132, in _main
    self = reduction.pickle.load(from_parent)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
EOFError: Ran out of input

Но когда я меняю лямбду-функцию паузы в аргументе target процесса на обычную функцию (то есть def sleep(): time.sleep(2) и process = mp.Process(target=sleep)) то код работает как надо. Если многопроцессность изменить на многопоточность то все будет работать правильно и с обычной функцией, и с лямбдой.

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

Версия питона 3.11.6

6
  • 2
    Про передачу аргументов в Procces, почитайте. Commented 24 дек. 2023 в 14:33
  • Я понял, вот так работает process = mp.Process(target=time.sleep, args=(2,)) хотя странно что в thread с лямбдой работает, а в process нет, ну и ладно. Commented 24 дек. 2023 в 14:50
  • 6
    Лямбда может ссылаться на локальные переменные - замыкание. А pickle не умеет сериализовать замыкание и передать его в другой процесс. Такое ограничение. Работают только глобальные функции данного модуля. Для них есть гарантия что они будут одинаковы во всех копиях процессов. Для многопоточности ограничения нет - не надо делать сериализацию. Commented 24 дек. 2023 в 14:57
  • 2
    Не нужно добавлять "закрыто" в заголовок вопроса. Вместо этого нужно отметить один из ответов принятым (можно и свой, но через 2 дня). "Закрытие" в терминах stackoverflow означает, что вопрос требует исправления и временно закрыт, в это время новые ответы добавлять нельзя.
    – insolor
    Commented 25 дек. 2023 в 13:58
  • 1
    Ты в курсе, что такое процессор и где их много? Ну и какое отношение это имеет к твоему коду?
    – Qwertiy
    Commented 25 дек. 2023 в 16:47

3 ответа 3

5

По-моему, в ошибке все сказано.

AttributeError: Can't pickle local object 'start.<locals>.<lambda>'

Не может он с лямбдой работать

Вместо этого используй:

process = mp.Process(target=time.sleep, target=(2,))

Помни, что ты можешь там вызывать функцию из модулей напрямую, а не создавать свою

1
  • 2
    В текущем виде ваш ответ непонятен. Пожалуйста, нажмите править под сообщением, чтобы добавить больше подробностей, которые помогут другим понять, как он отвечает на заданный вопрос. Вы можете найти больше информации о том, как писать хорошие ответы в Справке. Commented 24 дек. 2023 в 19:46
4

Process в Виндовс использует метод spawn. Этот метод запускает питон без контекста и импортирует в него функцию таргет. Импортировать можно только глобальную функцию. С лямбдами, локальными функциями и методами классов это работать не может.

В линукс используется метод fork который делает копию процесса и в этом случае работают лямбды.

1

Вот так работает:

process = mp.Process(target=time.sleep, args=(2,))

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

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