ok
Fork of rtos_queue by
Revision 1:d2ba5afbf91f, committed 2012-07-13
- Comitter:
- emilmont
- Date:
- Fri Jul 13 11:22:59 2012 +0000
- Parent:
- 0:e0607f77b5bc
- Child:
- 2:60e763987e7b
- Commit message:
- First implementation
Changed in this revision
| main.cpp | Show annotated file Show diff for this revision Revisions of this file |
| mbed-rtos.lib | Show annotated file Show diff for this revision Revisions of this file |
--- a/main.cpp Fri Jul 13 11:20:39 2012 +0000
+++ b/main.cpp Fri Jul 13 11:22:59 2012 +0000
@@ -0,0 +1,41 @@
+#include "mbed.h"
+#include "rtos.h"
+
+typedef struct {
+ float voltage; /* AD result of measured voltage */
+ float current; /* AD result of measured current */
+ uint32_t counter; /* A counter value */
+} message_t;
+
+MemoryPool<message_t, 16> mpool;
+Queue<message_t, 16> queue;
+
+/* Send Thread */
+void send_thread (void const *argument) {
+ uint32_t i = 0;
+ while (true) {
+ i++; // fake data update
+ message_t *message = mpool.alloc();
+ message->voltage = (i * 0.1) * 33;
+ message->current = (i * 0.1) * 11;
+ message->counter = i;
+ queue.put(message);
+ Thread::wait(1000);
+ }
+}
+
+int main (void) {
+ Thread thread(send_thread);
+
+ while (true) {
+ osEvent evt = queue.get();
+ if (evt.status == osEventMessage) {
+ message_t *message = (message_t*)evt.value.p;
+ printf("\nVoltage: %.2f V\n\r" , message->voltage);
+ printf("Current: %.2f A\n\r" , message->current);
+ printf("Number of cycles: %u\n\r", message->counter);
+
+ mpool.free(message);
+ }
+ }
+}
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/mbed-rtos.lib Fri Jul 13 11:22:59 2012 +0000 @@ -0,0 +1,1 @@ +http://mbed.org/users/mbed_official/code/mbed-rtos/#01158bb7600c
