c++ - 尝试将线程创建方法从 C 迁移到 C++ 不起作用

Question

我一直在寻找具体信息来解决我的问题，但我认为它太具体了。我正在开发一个项目，它以一种非常令人困惑的方式混合了 C 和 C++ 代码。最后，我不得不获取一些 C 代码并将其用于用 C++ 编译的文件中。我虽然它可以进行一些更改，但我发现了一个我无法自己解决的错误。这是关于线程的使用。

我已经将两个函数声明为公开的，因为我收到了它们，并在我的头文件 drviRIOAD_1D.h 中声明了它们，在我的类(class)drviRIOAD_1D :

void ai_pv_thread(void *p);
void aiDMA_thread(void *p);

然后我将其代码复制到我的 cpp 文件 drviRIOAD_1D.cpp 中:(我只包含有错误的代码部分)

void drviRIOAD_1D::aiDMA_thread(void *p){
 ai_pv_publish= (irio_dmathread_t*) malloc(sizeof(irio_dmathread_t)*irioPvt->DMATtoHOSTNCh[ai_dma_thread->id]);

    buffersize=irioPvt->DMATtoHOSTBlockNWords[ai_dma_thread->id];

    samples_per_channel=irioPvt->DMATtoHOSTBlockNWords[ai_dma_thread->id]*8; //Bytes per block
    samples_per_channel= samples_per_channel/irioPvt->DMATtoHOSTSampleSize[ai_dma_thread->id]; //Samples per block
    samples_per_channel= samples_per_channel/irioPvt->DMATtoHOSTNCh[ai_dma_thread->id];//Samples per channel per block

    // Ring Buffers for Waveforms PVs
    ai_dma_thread->IdRing= (void**) malloc(sizeof(epicsRingBytesId)*irioPvt->DMATtoHOSTNCh[ai_dma_thread->id]);
    // Creation and Launching of threads working as consumers for EPICS PVs publishing
    aux=(float**) malloc(sizeof(float*)*irioPvt->DMATtoHOSTNCh[ai_dma_thread->id]);
    for(i=0;i<irioPvt->DMATtoHOSTNCh[ai_dma_thread->id];i++){
        aux[i]=(float*) malloc(sizeof(float)*samples_per_channel);
        if(ch_nelm[chIndex+i]!=0){
            ai_dma_thread->IdRing[i]=epicsRingBytesCreate(samples_per_channel*irioPvt->DMATtoHOSTSampleSize[ai_dma_thread->id]*4096);//!<Ring buffer to store manage the waveforms.
            ai_pv_publish[i].IdRing=&ai_dma_thread->IdRing[i];
            ai_pv_publish[i].dma_thread_name=(char *)malloc(40);
            sprintf(ai_pv_publish[i].dma_thread_name,"%sPVPublisher%02d",ai_dma_thread->dma_thread_name,i);
            ai_pv_publish[i].id=i; //channel identifier
            ai_pv_publish[i].dmanumber=ai_dma_thread->id; //dma identifier
            ai_pv_publish[i].threadends=0;
            ai_pv_publish[i].endAck=0;
            ai_pv_publish[i].asynPvt=ai_dma_thread->asynPvt;
            ai_pv_publish[i].dma_thread_id=epicsThreadCreate(ai_pv_publish[i].dma_thread_name,
                                epicsThreadPriorityHigh,epicsThreadGetStackSize(epicsThreadStackBig),
                                (EPICSTHREADFUNC)ai_pv_thread,  
                                (void *)&ai_pv_publish[i]); //Here occurs the error, it means that ai_pv_thread argument does not work properly

}

最后一行给了我一个错误，如下:

../drviRIOAD_1D.cpp:1846: error: invalid use of member (did you forget the ‘&’ ?)

这是函数 ai_pv_thread(void *p)

void drviRIOAD_1D::ai_pv_thread(void *p){
//There is one thread per ringbuffer (per DMA channel)

irio_dmathread_t *pv_thread;
pv_thread=(irio_dmathread_t *)p;
irioDrv_t *irioPvt = &pv_thread->asynPvt->drvPvt;
float* pv_data;
int pv_nelem=4096,aux;
while (irio_threadsrun==0) {usleep(10000);}
aux=irioPvt->DMATtoHOSTChIndex[pv_thread->dmanumber]+pv_thread->id;

printf ("ch_nelm %d\n", ch_nelm[aux]);
pv_nelem=ch_nelm[aux];


pv_data = (float*) malloc(sizeof(float)*pv_nelem);
do{
    int NbytesDecimated;
    NbytesDecimated=epicsRingBytesUsedBytes(*pv_thread->IdRing);
    if(NbytesDecimated>=(sizeof(float)*pv_nelem))
    {
        if(epicsRingBytesIsFull(*pv_thread->IdRing)){
            //TODO: Error

        }

        epicsRingBytesGet(*pv_thread->IdRing,(char*)pv_data,sizeof(float)*pv_nelem);

        CallAIInsFloat32Array(pv_thread->asynPvt,CH,
                irioPvt->DMATtoHOSTChIndex[pv_thread->dmanumber]+pv_thread->id,pv_data,pv_nelem);
    }else{
        //@todo: fix this
        usleep(10000);
    }
}while (pv_thread->threadends==0);
free(pv_data);
free(pv_thread->dma_thread_name);
pv_thread->endAck=1;
}

我不明白的是为什么会出现错误，因为这段代码已经可以工作了。我认为这是因为迁移，但我无法解决它。

事实上，我有一个 cpp 的近示例，我一直在使用它，但没有结果。在本例中，他们使用静态回调创建了线程，该回调位于调用类内部函数的类外部。不同的是，类内部函数的参数是 void , void callbackTask()就我而言是 void ai_pv_thread(void *p) .

给我带来问题的函数来自外部API，它提供了C接口(interface)和C++接口(interface)，也许这也是一个问题？我认为我没有正确访问我的函数 ai_pv_thread，它是在没有参数的情况下调用的，但实际上它需要一个 void *p。不过，我尝试了一些更改，例如添加 '::' (EPICSTHREADFUNC)::ai_pv_thread 但在这种情况下，编译器告诉我错误:'::ai_pv_thread' 未声明。

有人可以向我解释一下 C 和 C++ 中的回调之间的区别，以便我可以解释这种行为吗？我必须做出什么改变才能让它发挥作用？我可以更改函数参数，例如静态或函数的位置，现在它们在类 drviRIOAD_1D 中是公共(public)的，但我可以将它们取出。

这是link to this API (只是为了了解函数epicsThreadCreate的api):
epicsThreadCreate --> 创建一个新线程。优先级和 stackSize 参数的使用取决于实现。某些实现可能会忽略其中一个或另一个，但为了可移植性，应该为两者指定适当的值。作为 stackSize 参数传递的值应通过调用 epicsThreadGetStackSize 获得。 funptr 参数指定实现线程的函数，parm 是传递给 funptr 的单个参数。当 funptr 返回时，线程终止。

它的界面:

epicsThreadId epicsThreadCreate(const char *name,
unsigned int priority, unsigned int stackSize,
EPICSTHREADFUNC funptr,void *parm);

Answer 1

假设 ai_pv_thread(void*) 是一个成员函数，那么您所做的就是未定义的行为。鉴于您遇到的错误，我倾向于这么认为。至start a thread using a member function you need to use a helper像这样:

static void pv_thread_start(void* in)
{
    if(!in)
    {
        return;
    }
    std::unique_ptr<data_holder> holder(static_cast<data_holder*>(in));
    holder->obj->ai_pv_thread(holder->data);
}

或者，您可以使用静态成员函数，但其​​语法很奇怪，我通常会避免使用它。

创建线程时，您可能需要传入一个具有 *this 和您需要的数据的 POD 对象，如下所示:

struct data_holder{
    drviRIOAD_1D* obj;
    ai_pv_publish* data;
};

在创建线程时:

auto data = std::make_unique<data_holder>({this, &ai_pv_publish[i]});
epicsThreadCreate(
    ai_pv_publish[i].dma_thread_name,
    epicsThreadPriorityHigh,
    epicsThreadGetStackSize(epicsThreadStackBig),
    // this cast is probably unncessary now
    static_cast<EPICSTHREADFUNC>(pv_thread_start),
    static_cast<void*>(data.release());