这是传递给线程声明的结构:
typedef struct {
int rowsPerThread;
int StartingRow;
double co[WIDTH][HEIGHT][2];
uint64_t total_iters;
} thdata;
下面是我如何使用它:(注意malloc)
/* data passed to each thread */
thdata *data[threads_num];
/* create threads */
for (i=0; i<threads_num; i++)
{
data[i]=(thdata *)malloc(sizeof(thdata));
data[i]->rowsPerThread= rowsPerThread;
data[i]->StartingRow= i*rowsPerThread;
for (i=i*rowsPerThread; i<rowsPerThread; i++)
memcpy(data[i]->co[i], Coordinates[i], sizeof (Coordinates) * HEIGHT * 2);
pthread_create(&thread[i], NULL, (void *) &threaded_calc, (void *) &data[i]);
free(data[i]);
}
我认为malloc()有问题。
这让我有了分段错误。
问题是,在创建pthread
之后,您立即在for
块中free
您的data[i]
,并且由于您无法知道thread
何时启动,因此在scheduler
有效启动thread
之前,data[i]
可能已释放。
因此,您应该在线程体内部调用free
。