Самообновляемый объект многопроцессорной обработки Python

self.thread.join(timeout=0) кажется бессмысленной строкой кода, поскольку join() обычно используется для ожидания завершения процесса в течение определенного периода времени, но в этом случае он вообще не ждет.

Судя по вашему коду, я не вижу ничего, что могло бы блокировать, но на некоторых платформах запуск нового процесса может занять некоторое время (иногда более 1 секунды) в зависимости от метода запуска процесса .

Учитывая, что magdate(), скорее всего, будет запускать новый процесс при каждом вызове, я подозреваю, что именно здесь и происходит «блокировка».

Поэтому вместо того, чтобы каждый раз запускать новый процесс в magdate(), я бы предложил вместо этого использовать объект Queue.

from multiprocessing import Queue, Process, Event

class AccMag():
    # Init manually to ensure access to and for internal functions
    def init(self):
        # This defines the hardware access
        self.i2c = busio.I2C(board.SCL, board.SDA)
        self.mag = adafruit_lis2mdl.LIS2MDL(self.i2c)
        self.accel = adafruit_lsm303_accel.LSM303_Accel(self.i2c)

        # Set up queue and a termination event
        self.queue = Queue()
        self.terminate_event = Event()

        # The process, named thread.  Yes, my cat is named Rex.
        self.thread = Process(target=self.threadmagdate, args=(self.queue, self.terminate_event))
        self.thread.start()

        # A counter I use to see how often the process has run.
        # Comparing this counter to a similar one in the display is how I know it's blocking.
        self.tc = 0

    def stop(self):
        self.terminate_event.set()  ## trigger termination event
        self.thread.join()  ## wait for process to terminate

    # The function that starts the process to update the values
    def magdate(self):
        # Check if new value is available
        if not self.queue.empty():
            x, y, z = self.queue.get()

            # Pull out new values
            self.magx = int(x)
            self.magy = int(y)
            self.magz = int(z)

            self.tc += 1

    # Get the data from the hardware into the pipe
    def threadmagdate(self, queue, terminate_event):
        while not terminate_event.is_set():  ## check if it's time to stop reading values
            queue.put(self.mag.magnetic)  ## insert new reading into queue

Что-то вроде этого должно работать с потоками:

class AccMag:
    # Init manually to ensure access to and for internal functions
    def __init__(self):
        # This defines the hardware access
        self.i2c = busio.I2C(board.SCL, board.SDA)
        self.mag = adafruit_lis2mdl.LIS2MDL(self.i2c)
        self.accel = adafruit_lsm303_accel.LSM303_Accel(self.i2c)

        self.mag_data = (0, 0, 0)
        self.update_count = 0

        self.thread = threading.Thread(target=self._mag_thread, daemon=True)
        self.thread.start()

    # Get the data from the hardware into the pipe
    def _mag_thread(self):
        while True:
            mag = tuple(map(int, self.mag.magnetic))
            self.mag_data = mag
            self.update_count += 1

С этой реализацией нет необходимости вручную вызывать magdata: просто возьмите значения x, y, z напрямую из .mag_data.

В главном приложении отображения скопируйте ссылку на кортеж mag_data в локальную переменную (например, cur_data = accmag.mag_data; x = cur_data[0]), а не обращайтесь напрямую к полям (например, x = accmag.mag_data[0]), чтобы избежать гонок с потоком обновления и просмотра частичных результатов.

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