我有以下代码导致在pthread_join
调用中出现段错误。对于很多行,我感到很抱歉,但是每个字符都很重要。如果重要的话,相同的代码可以在WinAPI下正常运行,并且没有任何错误。
void solution_of_matrix(int amount_of_threads, vector< vector<double> > &matrix)
{
pthread_t * threads = new pthread_t[amount_of_threads - 1];
matrix_struct * data = new matrix_struct[amount_of_threads];
/* ... */
for (size_t i = 0; i < amount_of_threads; ++i)
{
/* ... */
if (i == amount_of_threads - 1)
{
MyThreadProc(&data[i]);
}
else
{
pthread_create(&threads[i], 0, MyThreadProc, &data[i]);
}
}
for(int i = 0; i < amount_of_threads; ++i)
pthread_join(threads[i], 0); // <- ERROR
delete[] threads;
delete[] data;
}
和
MyThreadProc
:void* MyThreadProc(void* lpParam)
{
matrix_struct * data = (matrix_struct*)lpParam;
/*... */
pthread_mutex_lock(&mutex);
for (i = (data->i); i < (*data->matrix).size(); i++)
{
if ((*data->matrix)[i][i] == 0 )
for (j = (data->i + 1); j <(*data->matrix).size(); j++)
if ((*data->matrix)[j][i] != 0 )
{
vector< double > v;
for(size_t k = 0; k < (*data->matrix)[j].size(); ++k)
v.push_back((*data->matrix)[j][k]);
for( int q = 0; q < (*data->matrix)[j].size(); q++)
(*data->matrix)[j][q] = (*data->matrix)[i][q];
for ( int w = 0; w < (*data->matrix)[i].size(); w++)
(*data->matrix)[i][w] = v[w];
break;
}
}
for (i = (data->i); i < data->i + data->sz ; i++)
{
if ( i !=(*data->matrix).size() - 1)
{
tmp = (*data->matrix)[i][i];
for (j = n; j >= i; j--)
(*data->matrix)[i][j] /= tmp;
for (j = i+1; j < n; j++)
{
tmp = (*data->matrix)[j][i];
for (k = n; k >= i; k--)
(*data->matrix)[j][k] -= tmp*(*data->matrix)[i][k];
}
}
}
pthread_mutex_unlock(&mutex);
return 0;
}
在许多代码的结尾,我的
struct
:struct matrix_struct
{
vector< vector<double> > * matrix;
size_t i, sz;
};
工作选项是:
void solution_of_matrix(int amount_of_threads, vector< vector<double> > &matrix)
{
pthread_t * threads = new pthread_t[amount_of_threads];
matrix_struct * data = new matrix_struct[amount_of_threads];
/* ... */
for (size_t i = 0; i < amount_of_threads; ++i)
{
/* ... */
pthread_create(&threads[i], 0, MyThreadProc, &data[i]); //just simplifyed
}
for(int i = 0; i < amount_of_threads; ++i)
pthread_join(threads[i], 0);
delete[] threads;
delete[] data;
}
最佳答案
您之所以加入自己的行列,是因为最后一个线程没有启动,而是在使用创建其他线程的线程。检查pthread_join的错误代码...
关于c++ - pthread_join与核心转储段错误一起崩溃,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/13885609/