Mbed OSで複数のスレッドからのmailを待つ方法

開発環境

IDE：e2studio
マイコンボード：GR-LYCHEE
使用OS：Mbed OS

結論

複数のスレッドから異なる型のmailを送る方法が分からなかったので、
試行錯誤してみた結果、できた。

共用体は使っても使わなくてもどっちでもいいけど、
メモリ節約のためには使ったほうがいい。

本当にこの実装でいいのかは、検証が必要。

仕様

mailを送信するスレッドは、下記3スレッド。
それぞれ、異なる型のmailを送信している。

• send_thread
• send_thread2
• send_thread3

mailを受信待ちするスレッドは、下記スレッド。

• receive_thread

send_thread・send_thread2・send_thread3
のうち、どのスレッドがmailを送信してきたかは、
mail_typeで識別している。

コード

main.cpp

#include "mbed.h"

Serial pc(USBTX, USBRX);

typedef struct {
    uint32_t count1;
    uint32_t count2;
    uint32_t count3;
    uint32_t count4;
} a_mail_t;

typedef struct {
    uint8_t count13;
    uint8_t count14;
    uint8_t count15;
} b_mail_t;

typedef struct {
    char *msg;
} c_mail_t;

/* Mail */
typedef struct {
    uint32_t mail_type;
    union {
        a_mail_t a_mail;
        b_mail_t b_mail;
        c_mail_t c_mail;
    };
} mail_t;

Mail<mail_t, 32> mail_box;
Thread thread;
Thread thread2;
Thread thread3;
Thread thread4;

void send_thread3(void) {
    int i = 0;
    while (true) {
        i++;
        mail_t *mail = mail_box.alloc();
        mail->mail_type = 3;
        if (i % 2) {
            mail->c_mail.msg = "aaaaaaa";
        } else {
            mail->c_mail.msg = "bbbbbbb";
        }
        mail_box.put(mail);
        Thread::wait(3000);
    }
}

void send_thread(void) {
    uint32_t i = 3000000;
    while (true) {
        i++; // fake data update
        mail_t *mail = mail_box.alloc();
        mail->mail_type = 1;
        mail->a_mail.count1 = i;
        mail->a_mail.count2 = i * 2;
        mail->a_mail.count3 = i + 2;
        mail->a_mail.count4 = i % 6;
        mail_box.put(mail);
        Thread::wait(500);
    }
}

void send_thread2(void) {
    uint32_t i = 0;
    while (true) {
        i++; // fake data update
        mail_t *mail = mail_box.alloc();
        mail->mail_type = 2;
        mail->b_mail.count13 = i;
        mail->b_mail.count14 = i % 3;
        mail->b_mail.count15 = i * 5;
        mail_box.put(mail);
        Thread::wait(1000);
    }
}

void receive_thread(void) {
    while (true) {
        osEvent evt = mail_box.get();
        if (evt.status == osEventMail) {
            mail_t *mail = (mail_t *) evt.value.p;

            if (mail->mail_type == 1) {
                pc.printf("mail_type%d:%d,%d,%d,%d\n", mail->mail_type,
                        mail->a_mail.count1, mail->a_mail.count2,
                        mail->a_mail.count3, mail->a_mail.count4);
            } else if (mail->mail_type == 2) {
                pc.printf("mail_type%d:%d,%d,%d\n", mail->mail_type,
                        mail->b_mail.count13, mail->b_mail.count14,
                        mail->b_mail.count15);
            } else if (mail->mail_type == 3) {
                pc.printf("mail_type%d:%s\n", mail->mail_type,
                        mail->c_mail.msg);
            }
            mail_box.free(mail);
        }
    }
}

int main(void) {
    thread.start(send_thread);
    thread2.start(send_thread2);
    thread3.start(send_thread3);
    thread4.start(receive_thread);

    while (true) {

    }
}