c++ - 多线程快速排序

Question

很抱歉上一个问题。由于我是新来的，我不知道如何发布有关堆栈溢出的问题。所以这是我使用 Pthread 完成的多线程快速排序代码。但它无法正常工作。

    #include <iostream>
#include <pthread.h>
#define max 20
using namespace std;
class quick
{
    int arr[max];
    int n;

    public:

   int high;
    int low;
    quick(int n1)
    {
      n=n1;
    }
    quick(quick *obj)
    {

        this->n=obj->n;
        int i;
        for(i=0;i<this->n;i++)
        {
            this->arr[i]=obj->arr[i];
        }
    }
    void accept();
    void display();
    void quicksort(int,int);
    int partition(int,int);
    static void* thread_function(void *ptr)
    {
            quick* q= static_cast<quick *>(ptr);
        q->quicksort(q->low,q->high);
    }
};

void quick :: accept()
{
    int i;
    for(i=0;i<n;i++)
    {
        cout<<"Enter data: "<<endl;
        cin>>arr[i];
    }

}

void quick :: display()
{
    int i;
    cout<<"The array is: "<<endl;

    for(i=0;i<n;i++)
    {
        cout<<arr[i]<<" ";
    }

    cout<<endl;
}

void quick :: quicksort(int low,int high)
{


    int piv_index;
    pthread_t th1,th2;
    quick *q1,*q2;
    if(low<high)
    {
        piv_index=partition(low,high);


        q1= new quick(this);
        q2= new quick(this);

        q1->low=low;
        q1->high=piv_index-1;
        q2->low=piv_index+1;
        q2->high=high;

        void *obj1=reinterpret_cast<void *>(q1);
        void *obj2=reinterpret_cast<void *>(q2);

        pthread_create(&th1,NULL,quick :: thread_function,(void *)obj1);
        pthread_create(&th2,NULL,quick :: thread_function,(void *)obj2);

        pthread_join(th1,NULL);
        pthread_join(th2,NULL);
    }

}

int quick :: partition(int low,int high)
{
    int i,j,pivot,temp;

    pivot=arr[low];
    i=low+1;
    j=high;

    while(i<=j)
    {
        while(arr[i]<=pivot)
            i++;

        while(arr[j]>pivot)
            j--;

        if(i<j)
        {
            temp=arr[i];
            arr[i]=arr[j];
            arr[j]=temp;
        }
    }
    arr[low]=arr[j];
    arr[j]=pivot;

    return j;
}

int main()
{
    int no;
    cout<<"Enter the size of array: "<<endl;
    cin>>no;
    quick *q;
    q= new quick(no);
    q->accept();
    cout<<"Before Sorting: "<<endl;
    q->display();
    q->low=0;
    q->high=no-1;
    void *ptr=reinterpret_cast<void *>(q);
    quick::thread_function(ptr);

    cout<<"After Sorting: "<<endl;
    q->display();



    return 0;
}


    output:
Enter the size of array: 
5
Enter data: 
5
Enter data: 
4
Enter data: 
3
Enter data: 
2
Enter data: 
1
Before Sorting: 
The array is: 
5 4 3 2 1 
After Sorting: 
The array is: 
1 4 3 2 5 

请帮我弄清楚到底是什么错误......提前谢谢你

Answer 1

给出这些定义:

void *obj1=reinterpret_cast<void *>(q1);
void *obj2=reinterpret_cast<void *>(q2);

看起来您正在将 void** 转换为下面的 void*。我不认为你有意这样做:

pthread_create(&th1,NULL,quick :: thread_function,(void *)&obj1);
pthread_create(&th2,NULL,quick :: thread_function,(void *)&obj2);

删除和号，看看是否有帮助。

编辑:

此外，您的 quick 构造函数似乎正在从源对象复制数组，但我没有看到任何东西将其复制回原始对象，因此这些结果丢失了。最好单独存储数组并将指向它的指针从一个 quick 传递给下一个，这样它们都对同一份数据进行操作。

编辑(2):

快速而肮脏的方式:

将 int arr[max]; 从 quick 移动到 main 内部。将 int *arr; 放入 quick 中。像这样更改构造函数:

quick(int n1, int *a)
{
  n=n1;
  arr = a;
}
quick(quick *obj)
{
    this->n=obj->n;
    this->arr = obj->arr;
}

最后，将main中的q赋值改为q= new quick(no, arr);