Changeset 0f4f1b2 in mainline for kernel/test/synch

Timestamp:

2024-01-15T17:10:27Z (2 years ago)

Author:

Jiří Zárevúcky <zarevucky.jiri@…>

Branches:

master

Children:

e82879c

Parents:

a064d4f

git-author:

Jiří Zárevúcky <zarevucky.jiri@…> (2024-01-15 16:37:22)

git-committer:

Jiří Zárevúcky <zarevucky.jiri@…> (2024-01-15 17:10:27)

Message:

Add (and use) functions thread_start() and thread_detach()

Mostly cosmetic, with thread_start() replacing calls to thread_ready(),
but not consuming the passed reference, and thread_detach() being
synonym for thread_put(). Makes the code's function more obvious.

Also modify some threaded tests to use thread_join() for waiting,
instead of counting threads with atomics or semaphores.

Location:

kernel/test/synch

Files:

• semaphore1.c (modified) (1 diff)
• semaphore2.c (modified) (1 diff)

kernel/test/synch/semaphore1.c

@@ -89 +89 @@
                                 thrd = thread_create(consumer, NULL, TASK,
                                     THREAD_FLAG_NONE, "consumer");
-                                if (thrd)
-                                        thread_ready(thrd);
-                                else
+                                if (thrd) {
+                                        thread_start(thrd);
+                                        thread_detach(thrd);
+                                } else {
                                         TPRINTF("could not create consumer %d\n", i);
+                                }
                         }
                         for (k = 0; k < (4 - i); k++) {
                                 thrd = thread_create(producer, NULL, TASK,
                                     THREAD_FLAG_NONE, "producer");
-                                if (thrd)
-                                        thread_ready(thrd);
-                                else
+                                if (thrd) {
+                                        thread_start(thrd);
+                                        thread_detach(thrd);
+                                } else {
                                         TPRINTF("could not create producer %d\n", i);
+                                }
                         }
                 }

kernel/test/synch/semaphore2.c

@@ -92 +92 @@
                 thrd = thread_create(consumer, NULL, TASK,
                     THREAD_FLAG_NONE, "consumer");
-                if (thrd)
-                        thread_ready(thrd);
-                else
+                if (thrd) {
+                        thread_start(thrd);
+                        thread_detach(thrd);
+                } else {
                         TPRINTF("Error creating thread\n");
+                }
         }