【发布时间】:2015-12-11 02:01:45
【问题描述】:
我有一个程序需要对大量的大数值分布进行排序。为了减少执行此操作所需的时间,我正在尝试对此进行多线程处理。
我编写了一个小的、简单的程序抽象来尝试隔离问题。我相信我遇到了堆栈溢出,或者达到了操作系统的堆栈限制,因为我的测试程序在以下情况下反映了分段错误问题:
- 分布都是相同的值(意味着 qsort 会像垃圾一样运行)
- 线程已启用。
喵喵
#include <boost/thread/thread.hpp>
#include <vector>
#include <stdlib.h> // for rand()
void swapvals(double *distribution, const size_t &d1, const size_t &d2)
{
double temp = 0;
temp = distribution[d2];
distribution[d2] = distribution[d1];
distribution[d1] = temp;
//std::swap(distribution[d1], distribution[d2]);
}
size_t partition(double *distribution, size_t left, size_t right)
{
const double pivot = distribution[right];
while (left < right) {
while ((left < right) && distribution[left] <= pivot)
left++;
while ((left < right) && distribution[right] > pivot)
right--;
if (left < right)
{
swapvals(distribution, left, right);
}
}
return right;
}
void quickSort(double *distribution, const size_t left, const size_t right)
{
if (left >= right) {
return;
}
size_t part = partition(distribution, left, right);
quickSort(distribution, left, part - 1);
quickSort(distribution, part + 1, right);
}
void processDistribution(double *distributions, const size_t distribution_size)
{
std::clog << "beginning qsorting." << std::endl;
quickSort(distributions, 0, distribution_size - 1);
std::clog << "done qsorting." << std::endl;
}
int main(int argc, char* argv[])
{
size_t distribution_size = 65000;
size_t num_distributions = 10;
std::vector<double *> distributions;
// Create num_distributions distributions.
for (int i = 0; i < num_distributions; i++)
{
double * new_dist = new double[distribution_size];
for (int k = 0; k < distribution_size; k++)
{
// Works when I have actual numbers in the distributions.
// Seg faults when all the numbers are the same.
new_dist[k] =1;
//new_dist[k] = rand() % 1000 + 1; // uncomment this, and it works.
}
distributions.push_back(new_dist);
}
// Submit each distribution to a quicksort thread.
boost::thread_group threads;
for (std::vector<double *>::const_iterator it=distributions.begin(); it != distributions.end(); ++it)
{
// It works when I run processDistribution directly. Segfaults when I run it via threads.
//processDistribution(*it, distribution_size);
threads.create_thread(boost::bind(&processDistribution, *it, distribution_size));
}
threads.join_all();
// Show the results of the sort for all the distributions.
for (std::vector<double *>::const_iterator it=distributions.begin(); it != distributions.end(); ++it)
{
for (size_t i = 0; i < distribution_size; i++)
{
// print first and last 20 results.
if (i < 20 || i > (distribution_size - 20))
std::cout << (*it)[i] << ",";
}
std::cout << std::endl;
}
}
核心文件的 GDB 分析结果:
Error in re-setting breakpoint -1: aix-thread: ptrace (52, 18220265) returned -1 (errno = 3 The process does not exist.)
Error in re-setting breakpoint -1: aix-thread: ptrace (52, 18220265) returned -1 (errno = 3 The process does not exist.)
Error in re-setting breakpoint -2: aix-thread: ptrace (52, 18220265) returned -1 (errno = 3 The process does not exist.)
Error in re-setting breakpoint -3: aix-thread: ptrace (52, 18220265) returned -1 (errno = 3 The process does not exist.)
Core was generated by `testthreads'.
Program terminated with signal SIGSEGV, Segmentation fault.
#0 0x00000001000056bc in partition (distribution=0x1101d1430, left=0, right=63626) at testthreads.cpp:18
warning: Source file is more recent than executable.
18
(gdb) bt 7
#0 0x00000001000056bc in partition (distribution=0x1101d1430, left=0, right=63626) at testthreads.cpp:18
#1 0x0000000100005834 in quickSort (distribution=0x1101d1430, left=0, right=63626) at testthreads.cpp:42
#2 0x0000000100005850 in quickSort (distribution=0x1101d1430, left=0, right=63627) at testthreads.cpp:43
#3 0x0000000100005850 in quickSort (distribution=0x1101d1430, left=0, right=63628) at testthreads.cpp:43
#4 0x0000000100005850 in quickSort (distribution=0x1101d1430, left=0, right=63629) at testthreads.cpp:43
#5 0x0000000100005850 in quickSort (distribution=0x1101d1430, left=0, right=63630) at testthreads.cpp:43
#6 0x0000000100005850 in quickSort (distribution=0x1101d1430, left=0, right=63631) at testthreads.cpp:43
(More stack frames follow...)
(gdb) frame 0
#0 0x00000001000056bc in partition (distribution=0x1101d1430, left=0, right=63626) at testthreads.cpp:18
18
(gdb) info locals
pivot = 1
(gdb) info args
distribution = 0x1101d1430
left = 0
right = 63626
(gdb)
另外,我的实际程序处理更多的线程和分布。而且那里的 GDB 检查经常显示更多奇怪的堆栈跟踪,看起来像内存损坏(请注意如何使用 d1 = 12119 调用 swapVals,但在分区堆栈帧内它以 4568618016 的形式出现):
(gdb) bt 3
#0 0x00000001002aa0b8 in ScenRankReplacer<double>::swapvals (this=0xfffffffffffdfc8, distribution=..., d1=@0x1104c8178: 4568618016, d2=@0x1104c8140: 4568416720, ranking_values=0x1104c81d0,
r1=@0x1104c8170: 1152921504606838728, r2=@0x1002a16c8: 6917529029728344952) at ScenRankReplacer.h:96
#1 0x00000001002a7120 in ScenRankReplacer<double>::partition (this=0xfffffffffffdfc8, distribution=..., ranking_values=0x11069ae50, left=1, right=24237) at ScenRankReplacer.h:122
#2 0x00000001002a16c8 in ScenRankReplacer<double>::quickSort (this=0xfffffffffffdfc8, distribution=..., ranking_values=0x11069ae50, left=1, right=24237) at ScenRankReplacer.h:91
(More stack frames follow...)
(gdb) frame 1
#1 0x00000001002a7120 in ScenRankReplacer<double>::partition (this=0xfffffffffffdfc8, distribution=..., ranking_values=0x11069ae50, left=1, right=24237) at ScenRankReplacer.h:122
122 swapvals(distribution, mid, left, ranking_values, mid - 1, left - 1);
(gdb) p mid
$1 = 12119
(gdb) p left
$2 = 1
所以...我的问题:
- 我说的对吗?我达到堆栈限制了吗?
- 我到底如何确定是这种情况(除了我上面所做的推断)?有没有简单的方法来检测这些? GDB 线索还是什么?
- 为什么线程很重要?是否所有线程共享相同 堆栈限制?
- 最重要的:我如何才能让它发挥作用?!是一个 对海量数据集进行递归快速排序不可行?
编译级别 O2 出现错误。 螺纹型号:aix gcc 版本 4.8.3 (GCC)
【问题讨论】:
-
Ummm... 在调试多线程软件时,我检查的第一件事是:它是否在单线程上工作?自己判断是否达到筹码限制真的那么难吗?您应该能够获取给定数据集的每个递归和递归级别的堆栈大小。请记住,您是在问一个调试问题,说实话,您并不是很具体。在您的“我的问题”中有 9 个问题句......我可以提出至少 5 个后续问题,这对于问答格式是不可行的。至少在我看来。
-
我提到当不使用线程时它可以工作。 (当我使用 1 个或多个线程时它会失败)。您将如何获得所有线程中的堆栈大小和递归数?我在问题中添加了“调试”标签。
-
我建议在您的程序中添加更多日志。如果堆栈溢出实际发生 - 您的代码将在调用导致它的函数或 {} 块时崩溃。
-
它通过值将指针传递给函数。指向的数据一直在范围内,直到程序结束,所以它不会那样。
-
经过一些调查,我发现你不能 (stackoverflow.com/questions/15435087/…) 将 pthread 的堆栈大小设置为大于 PTHREAD_STACK_MIN + 0xFFFF 并且这个值对于你的用例来说是不够的(你得到 Bus error: 10 on #5422 具有最佳优化的快速排序递归调用)。我看到的最好的解决方案(没有完整的算法修改)是创建新进程而不是线程。进程的堆栈可以动态增长 (unix.stackexchange.com/questions/63742/…)
标签: c++ multithreading debugging gcc aix