Threading 2 функции - PullRequest
       0

Threading 2 функции

0 голосов
/ 03 апреля 2020

Я пытаюсь прочитать очень медленный датчик (1-проводный), продолжая работать с другими функциями. Я заменил датчики чтения со сном 3 se c. Я хотел бы понять, могу ли я одновременно показывать точное время каждую секунду, пока срабатывает датчик (подождите 3se c.). Эта концепция потоков является новой для меня.

import time
import threading
from tkinter import Tk

def events_every_second(): #update clock every second
    right_now = time.strftime("%I:%M:%S %p")#("%H:%M:%S")
    print("time is now",right_now)
    root.after(1000, events_every_second)
def one_wire():
    time.sleep(3)
    print("one_wire loop")
    root.after(3010, one_wire)

root = Tk()

t_one_wire = one_wire()
thread_one_wire = threading.Thread(target = t_one_wire)
thread_one_wire.start()

t_ees = events_every_second
thread_ees = threading.Thread(target = t_ees)
thread_ees.start()

root.mainloop()

Ответы [ 2 ]

0 голосов
/ 04 апреля 2020

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

Функция every_one_sec обрабатывается событиями планирования Tkinter - нет необходимости создайте для него поток.

Кроме этого, наиболее некорректной частью вашего кода был полный вызов one_wire перед созданием потока в t_one_wire = one_wire() - и тот факт, что он будет работать, также требует Ткинтер перезвонит. Tkinter хочет запускать все свои события в одном потоке - так что это может привести к проблемам.

Надеюсь, приведенных ниже комментариев достаточно для лучшего понимания

import time
import threading
from queue import Queue, Empty
from tkinter import Tk


def some_ui_code():
    global stop_reading
    stop_reading = True

def events_every_second(): #update clock every second
    right_now = time.strftime("%I:%M:%S %p")#("%H:%M:%S")
    print("time is now",right_now)
    try:
        result = queue.get(block=False)
    except Empty:
        result = None
    if result is not None:
        # code to display the result read from the sensor in tkinter interface goes here
        ...
    # tkinter, not a separate thread, handles this
    root.after(1000, events_every_second)

def one_wire(queue):
    # this is handled in a separate thread, and "does not know" about tkinter at all
    while not stop_reading:
        result = call_to_read_sensor()  # takes 3 seconds
        queue.put(result)
        print("one_wire loop")
        time.sleep(0.1)  # actual call to time.sleep to space sensor readings, if needed.


root = Tk()
stop_reading = False
queue = Queue()
# start events_every_second - tkinter will handle the subsequent calls with the `root.after` scheduling
events_every_second()

thread_one_wire = threading.Thread(target=t_one_wire, args=(queue,))
thread_one_wire.start()


root.mainloop()
0 голосов
/ 04 апреля 2020

Вы не должны использовать root.after(3010,one_wire), это приведет к зависанию вашего Tk GUI на 3 секунды и не будет обновляться.

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

def one_wire():
    time.sleep(3)
    print("one_wire_loop")

создайте новый поток для этой функции.

import threading

one_wire_thread = threading.Thread(target = one_wire, args = ())
one_wire_thread.start()

Обратите внимание, что приведенный выше код будет запускать вашу функцию только один раз. Вы можете создать функцию-обертку с while True:, чтобы она продолжала работать, в функции-обертке вы также можете проверить условие, чтобы остановить и сломать функцию и, таким образом, остановить функцию one_wire. Вы также можете сделать это в функции one_wire:

def one_wire():
    while True:
        time.sleep(3)
        print("one_wire_loop")
        if {"condition to stop reading sensor"}:
            break
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...