2 
gcc 4.7.2
c89
APR 1.4

こんにちは、

APRスレッドプール、イベントループ（ポーリング）、およびメッセージキュー（msgget、msgsnd、msgrcv）を使用しています。

現在、ctrl-cを押した場合にテストしています。whileをfalseに設定します。したがって、メッセージはシグナルハンドラーで送信され、whileループで受信されます。

ただし、msgrcvは私のイベントループでブロックされているようです。そのため、ライブラリから他のイベントを取得できません。私のイベントループでは、メッセージが受信されたかどうかを確認しています。ただし、メッセージの待機をブロックしていると思います。これにより、ループが停止し、ライブラリからイベントをキャプチャできなくなります。

メッセージキューを使用するのはこれが初めてです。

これが私のコードです。関連する部分だけをコピーしたので、短くするためにすべてのエラーチェックを削除しました。

現在、イベントループがキューからメッセージを受信できることをテストしているだけなので、ループを停止できます。

提案をありがとう、

#define MSG_KEY 0001L
static int msg_id = 0;
static volatile apr_status_t is_looping = FALSE;

/* Wait for these message commands */
typedef enum tag_msg_cmd {END_LOOP, START_LOOP} msg_cmd_e;

/* message queue data */
typedef struct tag_msg_data msg_data_t;
struct tag_msg_data {
    long mtype;
    msg_cmd_e msg_cmd;
};

int main(void)
{
    /* Create message queue */
    msg_id = msgget(MSG_KEY, 0666 | IPC_CREAT);

    /* Create thread pool */
    has_error = apr_thread_pool_create(&thd_pool,
                                       init_threads,
                                       max_threads,
                                       mem_pool_app);

   /* Start event loop */
   LOG_CHECK(apr_thread_pool_schedule(thd_pool,
                                       (apr_thread_start_t)event_loop,
                                       NULL,
                                       0,
                                       NULL) == APR_SUCCESS, "Failed to schedule event loop");

    /* Pause until ctrl-c */
    pause();

    /* Destroy all memory pools and threading pools */
}

/* Poll for incoming events */
static apr_status_t event_loop(void)
{
    msg_data_t msg_data;
    int evt_id = 0;
    int msg_id = 0;

    /* Connect to the message queue */
    msg_id = msgget(MSG_KEY, 0644);
    assert(msg_id != -1 && "Failed to connect to the message queue");
    LOG_DEBUG("Connected to message queue with msg ID [ %d ]", msg_id);

    while(is_looping) {
        /* Under development - Process incoming event from shared library */
        /* evt_id = sr_waitevt(timeout_ms); */
        /* process_event(evt_id); */

        LOG_DEBUG("Looping....");

        /* Should not be blocking here, as I need to receive other events */
        msgrcv(msg_id, &msg_data, (sizeof msg_data) - (sizeof(long)), 2, 0);
        LOG_DEBUG("Waiting...");
        if(msg_data.msg_cmd == END_LOOP) {
            LOG_DEBUG("END_LOOP event queue message has been received");
            break;
        }
        sleep(1);
    }

    return 1;
}

/* Signal handler will terminated application on ctrl-c */
static void signal_handler(int sig)
{
    msg_data_t msg_data = {2,  END_LOOP};
    int rc = 0;

    rc = msgsnd(msg_id,
                &msg_data,
                (sizeof msg_data) - (sizeof(long)),
                IPC_NOWAIT);

    assert(rc == 0 && "Failed to send data to the message queue");
}
4

1 に答える 1

1

（5番目のパラメーター）のフラグパラメーターmsgrcvをIPC_NOWAITに設定します。これにより、キューは非ブロッキングを受信します。

于 2012-12-21T04:04:29.837 に答える