modified: WaveClock/RTCClockApp.py

WaveClock/RTCClockApp.py

@@ -6,7 +6,7 @@ from tm1637 import TM1637
 from TimeSource import TimeSource
 from TimeSyncer import TimeSyncer
 from micropython import schedule
-import _thread
+from machine import Timer
 from machine import idle
 
 MODE_TIME = 0
@@ -32,8 +32,10 @@ class RTCClockApp(Debug):
         self.disp = display_dev
         self.timesrc = time_source
         self.timesync = time_sync
-        # 継続フラグ
-        self._continue = False
+        # タイマー10ms
+        self.tm = Timer()
+        # 表示更新処理中フラグ（キュー溢れ防止用）
+        self._updating = False
         # 1つ前の秒
         self.prev_sec = -1
         # 初期表示
@@ -90,12 +92,26 @@ class RTCClockApp(Debug):
 
         self.setup_rtc = True
     
-    def _update_display(self):
+    @micropython.native
+    def _timer_handler(self,t):
         """
-        表示の更新を行うスレッド
+        10msタイマー割り込みハンドラ
+        実際の処理はschedule()に委譲
         """
-        while self._continue:
-            time.sleep_ms(50)      # 50ms
+        # 前回の処理が終わっていない、またはキューが一杯の場合はスキップする
+        if not self._updating:
+            try:
+                schedule(self._update_display, None)
+                self._updating = True
+            except RuntimeError:
+                self.dprint("--- schedule() queue full ---")
+
+    @micropython.native
+    def _update_display(self, _):
+        """
+        表示の更新を行う（メインスレッドで実行）
+        """
+        try:
             now = time.localtime()
             sec = now[5]
             if self.prev_sec != sec or self.prev_mode != self.mode:
@@ -116,17 +132,14 @@ class RTCClockApp(Debug):
                     elif self.mode == MODE_SEC:
                         disp_str = "%2d%2d" % (now[4], now[5])
                 self.disp.show_str(disp_str)
+        finally:
+            # 処理完了（またはエラー発生）時にフラグを下ろす
+            self._updating = False
     
     def run(self):
         """
         アプリケーションメインループ
         """
-        self._continue = True   # スレッド起動
-        _thread.start_new_thread(self._update_display,())
-        try:
-            while True:
-                idle()
-        except Exception as e:   # なにか起きたら停止する
-            self.dprint(f"Main loop error: {e}")
-        finally:
-            self._continue = False
+        self.tm.init(mode=Timer.PERIODIC, period=10, callback=self._timer_handler)
+        while True:
+            idle()