我正在尝试实现一个创建线程的类，增加一个值并将其发送到另一个线程，该数字定义为 (value * value) % threads

#include <iostream>
#include <pthread.h>
#include <unistd.h>
#include <cstdlib>
#include <vector>

pthread_mutex_t m = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cv = PTHREAD_COND_INITIALIZER;
volatile int counter = 0;
volatile int maxval = 0;
volatile int next = 0;

extern "C" void *func(void *p);

class Worker {
private:
    pthread_t thread = 0;
    int nth = 0;
    int nproc = 0;
public:
    Worker () {};
    Worker(int _nproc, int _nth) {
        nth = _nth;
        nproc = _nproc;
    };
    void start() {
        pthread_create(&thread, NULL, func, NULL); // Line 27

    };
    void wait() {
        while (nth != next) {
            pthread_cond_wait(&cv, &m);
        }
    };
    void notify() {
        pthread_cond_broadcast(&cv);
    };
    void run() {
        while (counter != maxval) {
            pthread_mutex_lock(&m);
            Worker::wait();
            if (counter != maxval) {
                printf("%d %d\n", nth, counter);
                ++counter;
            }
            next = (counter * counter) % nproc;
            Worker::notify();
            pthread_mutex_unlock(&m);
        }
    };
    void join() {
        pthread_join(thread, NULL);
    }
};

extern "C" void *func(void *p) {
    Worker *w = reinterpret_cast<Worker*>(p);
    w->run();
    return NULL;
}

int main(int argc, char *argv[]) {
    int nthreads = atoi(argv[1]);
    maxval = atoi(argv[2]);
    std::vector<Worker> workers;
    for (int i = 0; i != nthreads; ++i) {
        workers.push_back(Worker(nthreads, i));
    }
    for (int i = 0; i != workers.size(); ++i) {
        workers[i].start();
    }
    for (int i = 0; i != workers.size(); ++i) {
        workers[i].join();
    }
    return 0;
}

无法检查算法是否正确，因为当我调用 pthread_create(第 27 行)时出现段错误

这是 gdb 所说的:

#0  0x0000000000400f5a in Worker::wait (this=0x0) at ht19-4.cpp:30
#1  0x0000000000400fd5 in Worker::run (this=0x0) at ht19-4.cpp:40
#2  0x0000000000400d26 in func (p=0x0) at ht19-4.cpp:57
#3  0x00007ffff76296aa in start_thread (arg=0x7ffff6f4f700)
    at pthread_create.c:333
#4  0x00007ffff735eeed in clone ()
    at ../sysdeps/unix/sysv/linux/x86_64/clone.S:109

谁能解释一下这个函数到底发生了什么？我该如何正确实现？

非常感谢。

最佳答案

你是 func 不处理传入的 NULL 而 pthread_create 的第 4 个参数是在第三个参数。

更改 func 以正确处理 NULL，你应该很好:

extern "C" void *func(void *p) {
    if (NULL == p)
        return NULL;
    Worker *w = reinterpret_cast<Worker*>(p);
    w->run();
    return NULL;
}

此外，+1 用于发布 gdb 输出，所以这里有一些更多信息:

如果我们向上跟踪您的堆栈跟踪(我按照它们发生的顺序输入它们)，我们会看到 func 完成了在 Worker 上转换和调用 run 的工作> 它从 NULL 转换而来。注意 (p=0x0) 和 (this=0x0):

#2  0x0000000000400d26 in func (p=0x0) at ht19-4.cpp:57
#1  0x0000000000400fd5 in Worker::run (this=0x0) at ht19-4.cpp:40

Worker::run 工作正常，因为它在到达之前只访问 counter、maxval 和 m Worker::wait()

#0  0x0000000000400f5a in Worker::wait (this=0x0) at ht19-4.cpp:30

在 Worker::wait() 中，您正在访问 nth，它是空 Worker 实例的成员，您最终得到了段错误.

关于c++ - 创建线程时出现段错误，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/34360289/