Qt распараллеливание сортировки

class MyThread : public QThread
{
    Q_OBJECT

    int* Buff;
    int l;
    int r;
    QSemaphore *s;

    void sort(int* Buff, int l, int r)
    {
    bool a = false;
    bool b = false;
    int i=l;
    int j=r;
    int x=Buff[(l+r)/2];
    do
    {
        while(Buff<x) ++i;
        while(Buff[j]>x) --j;
        if(i<=j)
        {
        std::swap(Buff,Buff[j]);
        i++; j--;
        }
    } while(i<=j);

    //если есть свободные ресурсы
    if(l<j && s->tryAcquire())
    {
        a = true;
        MyThread* t = new MyThread(Buff,l,j,s);
        t->start();
    }
    if(i<r && s->tryAcquire())
    {
        b = true;
        MyThread* t = new MyThread(Buff,i,r,s);
        t->start();
    }

    //если нет свободных ресурсов
    //a,b - чтобы знать, не запустилась ли какая из сортировок раньше
    if (l<j && !a)
        sort(Buff,l,j);
    if(i<r && !b)
        sort(Buff,i,r);
    }

public:
    MyThread(int* _Buff, int _l, int _r, QSemaphore* _s):Buff(_Buff),l(_l),r(_r)
    {
    s = _s;
    }
    void run()
    {
    sort(Buff,l,r);
    s->release();
    }
};


class _Sort
{
public:

    static int qSort(int* Buff, size_t Size, quint32 ThreadCount)
    {
    if (Buff == NULL || Size <= 1 ||
    ((ThreadCount & (ThreadCount-1)) != 0))
    {
        qDebug() << "Error in params";
        return 1;
    }
    QSemaphore *sem = new QSemaphore(ThreadCount);
    sem->acquire();
    MyThread* t = new MyThread(Buff,0, Size-1,sem);
    t->start();
    while(static_cast<quint32>(sem->available()) != ThreadCount);
    delete sem;
    return 0;
    }

    static void qSortOneThread(int* Buff, int l, int r)
    {
    int i=l;
    int j=r;
    int x=Buff[(l+r)/2];
    do
    {
        while(Buff<x) ++i;
        while(Buff[j]>x) --j;
        if(i<=j)
        {
        std::swap(Buff,Buff[j]);
        i++; j--;
        }
    } while(i<=j);

    if(l<j)
        qSortOneThread(Buff,l,j);
    if(i<r)
        qSortOneThread(Buff,i,r);
    }
};