0

以下程序崩溃

libc++abi.dylib: terminating with uncaught exception of type stxxl::io_error: Error in virtual void stxxl::ufs_file_base::lock() : fcntl(,F_SETLK,) path=/var/tmp/stxxl fd=5 : Resource temporarily unavailable: unspecified iostream_category error
Abort trap: 6

这看起来很像我的两个线程正在尝试使用相同的文件处理程序/文件来更新 stxxl 文件 til /var/tmp。

在 stxxl 中有多个线程使用多个文件的技巧吗？

#include <stxxl/queue>
#include <iostream>

#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <stdlib.h>




void test() {
  typedef stxxl::queue<unsigned int> queue;
  queue my_queue;
  for(unsigned long long i = 0; i != 1024L * 1024 * 1024; i++)
    my_queue.push(10);

  std::cout << "queue_size " << my_queue.size() << std::endl; 

  while(my_queue.size() != 0)
    my_queue.pop();

  std::cout << "queue_size " << my_queue.size() << std::endl; 
}

int main()
{
  pid_t pid;
  pid_t cpid;
  int status;


  pid = fork();

  if (pid == 0) 
    {
      test();
      exit(0);
    } else 
    {

      test();
      if ((cpid=wait(&status)) == pid){
        std::cout << "Child " << pid << " returned" << std::endl;
      }
    }

    return 0;
}
4

2 回答 2

3

使用 STXXL 1.4.0，您还可以在 .stxxl 配置文件中使用“###”。打开文件时，“###”将替换为当前 pid。

请注意，调用第一个 STXXL 函数时会自动打开磁盘文件。因此，必须将此类调用延迟到 fork() 之后，就像您在示例中所做的那样。

于 2014-01-20T16:47:12.327 回答
1

我自己找到了答案，一个解决方案是给每个线程自己的虚拟磁盘，我这样做是这样的：

  stxxl::config * cfg = stxxl::config::get_instance();

  std::string result; 
  std::ostringstream convert; 
  convert << id; // the id of the stream, to make th filenames different
  result = convert.str(); 
    std::string base_file = "/var/tmp/stxxl" + result;
  stxxl::disk_config disk1(base_file, 100 * 1024 * 1024, "syscall autogrow delete_on_exit");

  cfg->add_disk(disk1);
于 2014-01-20T19:19:20.083 回答