Как завершить выполнение первой функции из второй и наоборот?

Question

[FeeFort]

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

def foo(arg):
    if arg:
        # exit bar function

def bar(arg):
    if arg:
        # exit foo function

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

UPD: Функции работают одновременно, через Thread, может, через него можно что-то сделать.

Comments

[Алан Гибизов]

В приведённом примере функции могут быть вызваны либо последовательно, либо надо предпринимать дополнительные меры, чтобы запустить их одновременно.
Я думаю, что последовательно невозможно реализовать вашу задачу, по крайней мере в описанной форме.

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

[FeeFort]

Алан Гибизов, уже добавил UPD, что функции работают одновременно, не доглядел, что не дописал это

[Алан Гибизов]

FeeFort, почитайте тут.
Как я понимаю, возможно два разных варианта: либо глобальные переменные, в которых одна функция выставляет флаг, другая их периодически проверяет, с механизмом семафоров, чтобы они друг другу не мешали работать с этими глобальными переменными;
либо механизм очередей, в которые функции будут пихать флаги, а другие оттуда будут забирать их.
По первому варианту - он заморочный, но в общем понятный; а вот со вторым вроде кажется попроще, но там наверняка есть засада.
Надо курить маны… и пробовать.

[FeeFort]

Алан Гибизов, возникла идея попробовать сделать что-нибудь через Thread, и к успеху я почти пришёл, но не понятен один момент

a = Thread(target=check_keyboard)
b = Thread(target=check_mouse)
a.start()
b.start()

Чисто теоретически, должны запуститься обе функции, но запускается b, и только после выполнения b, запускается a.
С чем может быть связано? Полный код скину завтра, пишу через телефон, на компьютере QNA нормально не открывается.

[Алан Гибизов]

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

[Вячеслав]

FeeFort, с очередью норм будет работать.
При нажатии кнопки - queue.put(...)
А внутри в цикле проверяем не появился ли в очереди элемент queue.get_nowait(), и не забываем в цикле про паузы (например sleep).
Само собой разумеется нужно внимательно почитать статью, ссылку на которую дал Алан Гибизов и в зависимости от своих условий определить как именно будете работать с очередью.

[FeeFort]

Алан Гибизов, вот полный код

from pynput import keyboard, mouse
from threading import Thread

def console(s):
    print(s)

def check_keyboard(end: bool = False):
    if end == True:
        return False
    else:
        def on_release(key):
            console(key)
            return False

        with keyboard.Listener(
            on_release=on_release) as k_listener:
            k_listener.join()

        k_listener = keyboard.Listener(
            on_release=on_release)
        k_listener.start()

def check_mouse(end: bool = False):
    if end == True:
        return False
    else:
        def on_click(x, y, button, pressed):
            console(button)
            return False

        with mouse.Listener(
            on_click=on_click) as m_listener:
            m_listener.join()

        m_listener = mouse.Listener(
            on_click=on_click)
        m_listener.start()
    

keyboard100 = Thread(target = check_keyboard, daemon=True)
keyboard100.start()
mouse100 = Thread(target = check_mouse, daemon=True)
mouse100.start()

while True:
    if not keyboard100.is_alive():
        print("Mouse is end")
        break
    if not mouse100.is_alive():
        print("Keyboard is end")
        break

На половину успехом можно назвать то, что при запуске этого кода когда я нажимаю на кнопку мыши, функция ожидающая нажатие кнопки клавиатуры завершается, если реализовать написанное выше, то это уже можно считать успехом.
UPD: Смог заметить что если написать запуск потоков так:

keyboard100 = Thread(target = check_keyboard, daemon=True).start()
# и также с функцией мыши

То функции работают одновременно.

Answer 1

[Сергей П]

В питоне код может работать одновременно только в разных процессах. В рамах одного процесса треды не позволяют работать коду одновременно. Скорее всего у вас есть в функции место, где вызывается какой-то sleep или обращение к внешним библиотекам, на время выполнения которых управление переключается.
Это значит, что вы можете мониторите некое условие в цикле и ставить какой-то глобальный флаг, а значение этого флага отслеживать в цикле в другом треде.
Для таких целей есть такая структура данных, как семафор.
Однако, судя по вашему описанию задачи, у вас беда с архитектурой вашего решения. Приведите ваш код более етально и вам тут дудут советы как более правильно обработать ваши события, как более окрректно с архитектурной точки зрения построить ваш код.

Comments

[FeeFort]

Полный код скинул в комментарии.