3

我正在实现一个启动 4 个线程的程序。

功能是：

void* SOURCE_in(struct SOURCE_1*);
void* SOURCE_out(struct SOURCE*);
void* SINK_out(struct SINK_1*);
void* SINK_in(struct SINK*);

这些功能允许在 4 个块之间进行通信。块 1 与块 2 通信。块 2 与第三块共享信息。块 3 与块 4 通信信息。

我的问题在 main.c

int main(int argc, char** argv){

    extern int p, e_source, e_sink_1, l_sink, l_source_1, flag, ctr_source;
    extern int ctr_source_1, ctr_sink, ctr_sink1;

        SOURCE source;      /*C struct*/
        SINK sink;          /*C struct*/
        SOURCE_1 source_1;  /*C struct*/
        SINK_1 sink_1;      /*C struct*/

        HANDLE CHT[4];

        p = 0;
        e_source =  flag = 0;
        l_sink = e_sink_1 = l_source_1 = 1;
        max = 5;
        ctr_source = ctr_source_1 = ctr_sink = ctr_sink_1 = 0;

        /*Initialize FIFO*/
        F *f1 = fifo_init(10);
        F *f2 = fifo_init(10);

        /*Connect FIFO and modules*/
        source.output_source = f1;
        sink.input_sink = f1;

        sink_1.output_sink = f2;
        source_1.input_source = f2;

        /*Create Threads*/
        CHT[0] = (HANDLE)_beginthread((void (*)(void *))&SOURCE_out, 0, &f1);
        CHT[1] = (HANDLE)_beginthread((void (*)(void *))&SINK_in, 0, &f1);
        CHT[2] = (HANDLE)_beginthread((void (*)(void *))&SINK_out, 0, &f2);
        CHT[3] = (HANDLE)_beginthread((void (*)(void *))&SOURCE_in, 0, &f2);

        /* Wait until all threads have terminated */

        WaitForSingleObject(CHT[0], INFINITE);
        WaitForSingleObject(CHT[1], INFINITE);
        WaitForSingleObject(CHT[2], INFINITE);
        WaitForSingleObject(CHT[3], INFINITE);

        getchar();

        return 0;}

我读到 WaitForSingleObject 函数不适用于 _beginthread.... 但我的函数不是 nunsigned __stdcall 类型...

我构建了没有错误的程序，并使用断点对其进行了测试，一切正常。当我编译我有这个问题：

线程“Win32 线程”(0x11ec) 已退出，代码为 0 (0x0)。线程“Win32 线程”(0x918) 已退出，代码为 0 (0x0)。线程“Win32 线程”(0x8a4) 已退出，代码为 0 (0x0)。线程“Win32 线程”(0x2a8) 已退出，代码为 -1073741510 (0xc000013a)。线程“Win32 线程”(0x12f8) 已退出，代码为 -1073741510 (0xc000013a)。程序“[3984] SW=SW.exe: Native”已退出，代码为 -1073741510 (0xc000013a)。

程序永远不会到达函数 getchar()

在做这个程序之前，我做了一个程序，在两个块之间进行通信，一个读，另一个写。在那种情况下，我没有问题。

如果我不使用 WaitForSingleObject 函数，问题就会消失，但我的程序几乎总是在完成之前停止。

每个线程使用的函数在中断时停止。但我希望其他的继续直到它出现中断..

4

2 回答 2

5

的文档_beginthread说明您不能使用其中一种等待功能：

以下示例代码演示了如何将 _beginthreadex 返回的线程句柄与同步 API WaitForSingleObject 一起使用。主线程在继续之前等待第二个线程终止。当第二个线程调用 _endthreadex 时，它会导致其线程对象进入信号状态。这允许主线程继续运行。这不能用 _beginthread 和 _endthread 完成，因为 _endthread 调用 CloseHandle，在线程对象设置为信号状态之前将其销毁。

而本文也为您提供了解决方案，即改为使用_beginthreadex。

我认为当您这么说时，您在问题中暗示了这一点

但我的功能不是 __stdcall

您只需更改函数即可使用__stdcall调用约定。

于 2012-05-04T12:04:28.610 回答
0

我不知道这是否有帮助，但您可能想尝试一下。我认为 WaitForSingleObject 仅适用于 Windows API。因此，您需要使用创建线程CreateThread（您可以在 tge MSDN 中搜索 API，它比 beginthread 稍微复杂一些，但并不复杂，如果您不了解安全性等，大多数不熟悉的结构可以设置为 NULL） . CreateThread 返回一个您可以等待的句柄。

我认为beginthread返回一些你等不及的东西，也就是说，WaitForSingleObject 的行为将是未定义的。在这种情况下，它可能会永远等待，因此不会调用 getchar。

于 2012-05-04T12:03:27.003 回答