1

我有一个服务器应用程序，它为每个传入请求创建新线程。

但是，每隔一段时间，它就会创建一个线程 ID = 0 的线程（使用 pthread_equal 来检查）。我有一个结构，其中包含我传递给 pthread_create 中指定的函数的线程 ID，并且正在那里进行检查。

为什么会创建一个 ID = 0 的线程？如果发生这种情况，我能做些什么吗？我不能使用这个线程并想立即退出它。

==================================================== ====================

typedef struct 
{
    pthread_t tid;
    other_struct_t Other;
} data_ptr_t;

void * worker(void * arg)
{
    data_ptr_t local_data;
    data_ptr_t * incoming_data = (data_ptr_t *) arg;
    if (NULL == incoming_data || NULL == incoming_data->Other)
    {
        printf("invalid input\n");
    }
    else if (pthread_equal(incoming_data->tid, 0))
    {
        printf("invalid thread id\n");
    }
    else
    {
        // add to global thread pool
        // do other stuff here
        // remove from global thread pool
    }
}

int main()
{
    // server socket stuff
    while (1)
    {
        // if incoming connection is valid
        data_ptr_t data;
        int error = pthread_create(&(data.tid), NULL, (void * (*) (void *)) worker, (void *) &data);
        if (0 != errror)
        {
            printf("could not create thread (%d)\n", error);
        }
        else
        {
            pthread_detach(data.tid);
            printf("thread dispatched\n");
        }
    }
}

注意：如果我创建的线程数低于 50 左右，它工作正常。超过 70 个，大多数线程都可以正常运行，其余线程最终打印“无效线程 id”。

注意：这是在 Linux 上。

4

1 回答 1

3

你不能这样做：

while (1)
{
    // if incoming connection is valid
    data_ptr_t data;
    int error = pthread_create(&(data.tid), 
        NULL, (void * (*) (void *)) worker, (void *) &data);

你data_ptr_t是堆栈上的局部变量。在while循环的下一次迭代中，该变量被破坏/消失/无效。

workerwhile 循环可能在新线程开始运行并使用您传递给它的数据之前很久就开始另一个迭代。相反，动态分配data你传递给工作线程的，这样你就可以确定它仍然有效。

于 2013-11-08T18:32:02.647 回答