Use Arduino_Threads for Threadsafe_Serial_Reader.

Author: aentinger

examples/Threadsafe_IO/Threadsafe_Serial_Reader/SharedVariables.h

@@ -0,0 +1,28 @@
+void setup()
+{
+  Serial.begin(9600);
+
+  Serial.block();
+  Serial.println("Thread #1 started.");
+  Serial.unblock();
+}
+
+void loop()
+{
+  /* Read data from the serial interface into a String. */
+  String serial_msg;
+  while (Serial.available())
+    serial_msg += (char)Serial.read();
+
+  /* Print thread id and chip id value to serial. */
+  if (serial_msg.length())
+  {
+    Serial.block();
+    Serial.print("[");
+    Serial.print(millis());
+    Serial.print("] Thread #1: ");
+    Serial.print(serial_msg);
+    Serial.println();
+    Serial.unblock();
+  }
+}

examples/Threadsafe_IO/Threadsafe_Serial_Reader/Thread_1.inot

@@ -0,0 +1,28 @@
+void setup()
+{
+  Serial.begin(9600);
+
+  Serial.block();
+  Serial.println("Thread #2 started.");
+  Serial.unblock();
+}
+
+void loop()
+{
+  /* Read data from the serial interface into a String. */
+  String serial_msg;
+  while (Serial.available())
+    serial_msg += (char)Serial.read();
+
+  /* Print thread id and chip id value to serial. */
+  if (serial_msg.length())
+  {
+    Serial.block();
+    Serial.print("[");
+    Serial.print(millis());
+    Serial.print("] Thread #2: ");
+    Serial.print(serial_msg);
+    Serial.println();
+    Serial.unblock();
+  }
+}

examples/Threadsafe_IO/Threadsafe_Serial_Reader/Thread_2.inot

@@ -0,0 +1,28 @@
+void setup()
+{
+  Serial.begin(9600);
+
+  Serial.block();
+  Serial.println("Thread #3 started.");
+  Serial.unblock();
+}
+
+void loop()
+{
+  /* Read data from the serial interface into a String. */
+  String serial_msg;
+  while (Serial.available())
+    serial_msg += (char)Serial.read();
+
+  /* Print thread id and chip id value to serial. */
+  if (serial_msg.length())
+  {
+    Serial.block();
+    Serial.print("[");
+    Serial.print(millis());
+    Serial.print("] Thread #3: ");
+    Serial.print(serial_msg);
+    Serial.println();
+    Serial.unblock();
+  }
+}

examples/Threadsafe_IO/Threadsafe_Serial_Reader/Thread_3.inot

@@ -4,76 +4,46 @@
 
 #include <Arduino_Threads.h>
 
-/**************************************************************************************
- * CONSTANTS
- **************************************************************************************/
-
-static size_t constexpr NUM_THREADS = 5;
-
-/**************************************************************************************
- * FUNCTION DECLARATION
- **************************************************************************************/
-
-void serial_thread_func();
-
-/**************************************************************************************
- * GLOBAL VARIABLES
- **************************************************************************************/
-
-static char thread_name[NUM_THREADS][32];
-#undef Serial
-#ifdef ARDUINO_PORTENTA_H7_M4
-  SerialDispatcher Serial(Serial1); /* No SerialUSB for Portenta H7 / M4 Core */
-#else
-  SerialDispatcher Serial(SerialUSB);
-#endif
-
 /**************************************************************************************
  * SETUP/LOOP
  **************************************************************************************/
 
 void setup()
 {
-  /* Fire up some threads all accessing the LSM6DSOX */
-  for(size_t i = 0; i < NUM_THREADS; i++)
-  {
-    snprintf(thread_name[i], sizeof(thread_name[i]), "Thread #%02d", i);
-    rtos::Thread * t = new rtos::Thread(osPriorityNormal, OS_STACK_SIZE, nullptr, thread_name[i]);
-    t->start(serial_thread_func);
-  }
-}
+  Serial.begin(9600);
+  while (!Serial) { }
 
-void loop()
-{
+  Thread_1.start();
+  Thread_2.start();
+  Thread_3.start();
 
+  Serial.block();
+  Serial.println("Thread #0 started.");
+  Serial.unblock();
 }
 
-/**************************************************************************************
- * FUNCTION DEFINITION
- **************************************************************************************/
-
-void serial_thread_func()
+void loop()
 {
-  Serial.begin(9600);
+  /* Read data from the serial interface into a String. */
+  String serial_msg;
+  while (Serial.available())
+    serial_msg += (char)Serial.read();
 
-  for(;;)
+  /* Print thread id and chip id value to serial. */
+  if (serial_msg.length())
   {
-    /* Sleep between 5 and 500 ms */
-    rtos::ThisThread::sleep_for(rtos::Kernel::Clock::duration_u32(random(5,500)));
-
-    /* Read data from the serial interface into a String. */
-    String serial_msg;
-    while (Serial.available())
-      serial_msg += (char)Serial.read();
-
-    /* Print thread id and chip id value to serial. */
-    if (serial_msg.length())
-    {
-      char msg[64] = {0};
-      snprintf(msg, sizeof(msg), "[%05lu] %s: %s ...", millis(), rtos::ThisThread::get_name(), serial_msg.c_str());
-      Serial.block();
-      Serial.println(msg);
-      Serial.unblock();
-    }
+    Serial.block();
+    Serial.print("[");
+    Serial.print(millis());
+    Serial.print("] Thread #0: ");
+    Serial.print(serial_msg);
+    Serial.println();
+    Serial.unblock();
   }
+
+  /* If we don't hand back control then the main thread
+   * will hog the CPU and all other thread's won't get
+   * time to be executed.
+   */
+  rtos::ThisThread::yield();
 }