3

似乎通过骨架/内容机制发送 stl 复杂数据不起作用。

这是一个显示问题的简单代码：

#include <boost/mpi.hpp>
#include <boost/serialization/complex.hpp>
#include <boost/serialization/vector.hpp>
#include <iostream>
namespace mpi = boost::mpi;
using namespace std;

int main(int argc, char* argv[])
{
     mpi::environment env(argc, argv);
     mpi::communicator world;
     int NN=world.size();
     int myid=world.rank();

     if (myid == 0)
     {
         int N = 10;
         vector <complex<double> > l(N);
         for (int p=1; p!=NN; p++)
             {
             int taskid=1;
             world.send(p, 0, taskid);
             world.send(p, 1, mpi::skeleton(l));
         }
         mpi::content c = mpi::get_content(l);
             for (int n = 0; n!=l.size() ; n++)
         {
             l[n]=complex<double>(1.0,1.0);
         }
         for (int p=1; p!=NN; p++)
         {
                 world.send(p, 1, c);
         }
     }
     else if (myid == 2)
     {
         vector <complex<double> > l;
         mpi::content c;
         world.recv(0, 1, mpi::skeleton(l));
         c = mpi::get_content(l);
         world.recv(0, 1, c);
         for (int n=0; n!=l.size(); n++)
         {
                 cout << l[n] << " ";
         }
         cout << endl;
     }
}

输出中向量 l 的条目不是 (1.0,1.0) 但它们似乎未初始化。这仅在使用复杂数据类型和骨架/内容机制时才会发生。

有谁知道，如果这是一个内置问题，或者我做错了什么？

4

3 回答 3

3

我最近在我的一个课程中遇到了类似的问题，在调试器中逐步完成序列化过程之后，我想我知道发生了什么。问题是在序列化运算符中使用临时变量。在 boost/serialization/complex.hpp 中，序列化函数如下所示：

template<class Archive, class T>
inline void save(
    Archive & ar,
    std::complex< T > const & t,
    const unsigned int /* file_version */
){
    const T re = t.real();
    const T im = t.imag();
    ar << boost::serialization::make_nvp("real", re);
    ar << boost::serialization::make_nvp("imag", im);
}

template<class Archive, class T>
inline void load(
    Archive & ar,
    std::complex< T >& t,
    const unsigned int /* file_version */ 
){
    T re;
    T im;
    ar >> boost::serialization::make_nvp("real", re);
    ar >> boost::serialization::make_nvp("imag", im);
    t = std::complex< T >(re,im);
}

请注意，序列化是通过临时对象完成的。get_content 功能通过构建 MPI 数据类型来工作，该数据类型实际上是内存中内容位置的映射。收到消息时，MPI 将数据直接复制到这些位置，而不调用任何序列化操作符。问题是当“保存”使用临时对象时，get_content() 不会获取实际数据的位置而是临时对象，因此接收到的数据没有放在正确的位置。

为了使骨架/内容功能正常工作，我的印象是保存函数（这是 get_content() 调用的）必须直接且仅序列化对象的数据成员。在这种情况下它不能，因为它无法访问复杂的内部表示。我认为，必须将序列化运算符编写为类的成员。

（Boost::MPI 文档中似乎根本没有提到这些限制。）

于 2011-11-28T17:17:54.403 回答
0 
namespace boost { 
namespace mpi {
    template <>
    struct is_mpi_datatype< complex<double> > : mpl::true_ { };
} }

使用它可以解决问题。In Boost 序列化优化

于 2014-03-11T09:58:59.870 回答
0

这是该问题的可能解决方法：

我为复杂类型编写了自己的序列化：

#include <boost/mpi.hpp>
#include <boost/serialization/vector.hpp>
#include <iostream>
namespace mpi = boost::mpi;
using namespace std;

namespace boost
{
    namespace serialization
    {
        template<class Archive>
        void serialize(Archive & ar, complex<double> & g, const unsigned int version)
        {
            ar & g.real();
            ar & g.imag();
        }
    }
}

int main(int argc, char* argv[])
{
    mpi::environment env(argc, argv);
    mpi::communicator world;
    int NN=world.size();
    int myid=world.rank();

    if (myid == 0) 
    {
        int N = 10;
        vector <complex<double> > l(N);
        for (int p=1; p!=NN; p++)
        {
            world.send(p, 1, mpi::skeleton(l));
        }
        mpi::content c = mpi::get_content(l);
        for (int n = 0; n!=l.size() ; n++) 
        {
            l[n]=complex<double>(1.0,1.0);
        }
        for (int p=1; p!=NN; p++)
        {
            world.send(p, 1, c);
        }
    } 
    else 
    {
        vector <complex<double> > l;
        mpi::content c;
        world.recv(0, 1, mpi::skeleton(l));
        c = mpi::get_content(l);
        world.recv(0, 1, c);
        for (int n=0; n!=l.size(); n++)
        {
            cout << l[n] << " ";
        }
        cout << endl;
    }
}
于 2011-12-07T15:12:40.833 回答