Возвращение структуры из потоковой функции

#include <iostream>
#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <time.h>
using namespace std;
pthread_mutex_t mutex;
struct Data
{
    int *mas;
    int param;
    int length;
};
int *colMult(int *mas, int param, int length)
{
    for (int i = 0; i < length; i++)
        mas[i] *= param;
    return mas;
}
void *colFunc(void *lpParam)
{
    struct Data dt = *((struct Data *)lpParam);
    pthread_mutex_lock(&mutex);
    Data *d = (struct Data*)malloc(sizeof(struct Data));
    d->mas = colMult(dt.mas, dt.param, dt.length);
    d->length = dt.length;
    cout << "Results in thread: "<<endl;
    for (int i = 0; i < dt.length; i++)
        cout << d->mas[i] << " ";
    cout << endl;
    pthread_mutex_unlock(&mutex);
    return d;
}
int main()
{
    setlocale(LC_ALL, "Russian");
    pthread_mutex_init(&mutex, NULL);
    const int n = 3, m = 3;
    int **mas = new int*[n];
    pthread_t *th = new pthread_t[m];
    for (int i = 0; i < n; i++)
        mas[i] = new int[m];
    cout << "Матрица: " << endl;
    srand(time(NULL));
    for (int i = 0; i < n; i++)
    {
        for (int j = 0; j < m; j++)
        {
            mas[i][j] = rand()%10;
            cout << mas[i][j] << " ";
        }
        cout << endl;
    }
    cout << endl;
    Data dt;
    cout << "Вектор: " << endl;
    int *vect = new int[m];
    int *tempMas = new int[m];
    srand(time(NULL));
    for (int j = 0; j < m; j++)
        {
            vect[j] = rand()%10;
            tempMas[j] = 0;
            cout << vect[j] << " ";
        }
    for (int i = 0; i < m; i++)
    {
        for (int j = 0; j < n; j++)
        {
            tempMas[j] = mas[j][i];
        }
        cout << endl;
        dt.length = n;
        dt.mas = tempMas;
        dt.param = vect[i];
        pthread_create(&th[i], NULL, colFunc, &dt);
        usleep(10000);
    }
    void *r;
    int *resultMas = new int[n];
    for (int i = 0; i < n; i++)
    {
        resultMas[i] = 0;
    }
    cout << endl;
    for (int i = 0; i < m; i++)
    {
        pthread_join(th[i], (void**)&r);
        struct Data tmp = *((struct Data *)r);
        for (int j = 0; j < tmp.length; j++)
        {
            resultMas[j] += tmp.mas[j];
            cout << resultMas[j] << " ";
        }
        cout << endl;
       usleep(10000);
    }
    cout << "Результат: " << endl;
    for (int i = 0; i < m; i++)
    {
        cout << resultMas[i] << " ";
    }
    cout << endl;
    for (int i = 0; i < n; i++)
        delete[] mas[i];
    delete []mas;
    delete []vect;
    delete []th;
    delete []resultMas;
    return 0;
}

    for (int i = 0; i < m; i++)
    {
        for (int j = 0; j < n; j++)
        {
            tempMas[j] = mas[j][i];
        }
        cout << endl;
        dt.length = n; // перезатираем значение
        dt.mas = tempMas; // перезатираем указатель
        dt.param = vect[i]; // перезатираем значение
// в остальных потоках сейчас все значения соответствуют значениями в этих трех полях на последней итерации
// И это не говоря уже про ошибки, связанные с отсутствием синхронизации общего dt
        pthread_create(&th[i], NULL, colFunc, &dt);
        usleep(10000);
    }

void *colFunc(void *lpParam)
{
    struct Data dt = *((struct Data *)lpParam);
    pthread_mutex_lock(&mutex);
    Data *d = (struct Data*)malloc(sizeof(struct Data));
    d->mas = colMult(dt.mas, dt.param, dt.length);
    d->length = dt.length;
    cout << "Results in thread: "<<endl;
    for (int i = 0; i < dt.length; i++)
        cout << d->mas[i] << " ";
    cout << endl;
    pthread_mutex_unlock(&mutex);
    return d;
}