Use Arduino_Threads for Threadsafe_Serial_Write.

Author: aentinger

examples/Threadsafe_IO/Threadsafe_Serial_Writer/SharedVariables.h

@@ -0,0 +1,14 @@
+void setup()
+{
+  Serial.begin(9600);
+}
+
+void loop()
+{
+  Serial.block();
+  Serial.print("[");
+  Serial.print(millis());
+  Serial.print("] Thread #1: Lorem ipsum ...");
+  Serial.println();
+  Serial.unblock();
+}

examples/Threadsafe_IO/Threadsafe_Serial_Writer/Thread_1.inot

@@ -0,0 +1,14 @@
+void setup()
+{
+  Serial.begin(9600);
+}
+
+void loop()
+{
+  Serial.block();
+  Serial.print("[");
+  Serial.print(millis());
+  Serial.print("] Thread #2: Lorem ipsum ...");
+  Serial.println();
+  Serial.unblock();
+}

examples/Threadsafe_IO/Threadsafe_Serial_Writer/Thread_2.inot

@@ -0,0 +1,14 @@
+void setup()
+{
+  Serial.begin(9600);
+}
+
+void loop()
+{
+  Serial.block();
+  Serial.print("[");
+  Serial.print(millis());
+  Serial.print("] Thread #3: Lorem ipsum ...");
+  Serial.println();
+  Serial.unblock();
+}

examples/Threadsafe_IO/Threadsafe_Serial_Writer/Thread_3.inot

@@ -4,71 +4,32 @@
 
 #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);
-  }
-}
-
-void loop()
-{
+  Serial.begin(9600);
+  while (!Serial) { }
 
+  Thread_1.start();
+  Thread_2.start();
+  Thread_3.start();
 }
 
-/**************************************************************************************
- * FUNCTION DEFINITION
- **************************************************************************************/
-
-void serial_thread_func()
+void loop()
 {
-  Serial.begin(9600);
-
-  for(;;)
-  {
-    /* Sleep between 5 and 500 ms */
-    rtos::ThisThread::sleep_for(rtos::Kernel::Clock::duration_u32(random(5,500)));
-    /* Print thread id and chip id value to serial. */
-    char msg[64] = {0};
-    snprintf(msg, sizeof(msg), "[%05lu] %s: Lorem ipsum ...", millis(), rtos::ThisThread::get_name());
-    /* Every Serial.print/println() encapsulated between
-     * block/unblock statements will only be printed after
-     * a block statement has occurred.
-     */
-    Serial.block();
-    Serial.println(msg);
-    Serial.unblock();
-  }
+  Serial.block();
+  Serial.print("[");
+  Serial.print(millis());
+  Serial.print("] Thread #0: Lorem ipsum ...");
+  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();
 }