diff options
Diffstat (limited to 'libs/mpi/example/hello_world_nonblocking.cpp')
-rw-r--r-- | libs/mpi/example/hello_world_nonblocking.cpp | 36 |
1 files changed, 36 insertions, 0 deletions
diff --git a/libs/mpi/example/hello_world_nonblocking.cpp b/libs/mpi/example/hello_world_nonblocking.cpp new file mode 100644 index 000000000..c65247b99 --- /dev/null +++ b/libs/mpi/example/hello_world_nonblocking.cpp @@ -0,0 +1,36 @@ +// Copyright (C) 2006 Douglas Gregor <doug.gregor@gmail.com> + +// Use, modification and distribution is subject to the Boost Software +// License, Version 1.0. (See accompanying file LICENSE_1_0.txt or copy at +// http://www.boost.org/LICENSE_1_0.txt) + +// A simple Hello, world! example using Boost.MPI message passing. + +#include <boost/mpi.hpp> +#include <iostream> +#include <boost/serialization/string.hpp> // Needed to send/receive strings! +namespace mpi = boost::mpi; + +int main(int argc, char* argv[]) +{ + mpi::environment env(argc, argv); + mpi::communicator world; + + if (world.rank() == 0) { + mpi::request reqs[2]; + std::string msg, out_msg = "Hello"; + reqs[0] = world.isend(1, 0, out_msg); + reqs[1] = world.irecv(1, 1, msg); + mpi::wait_all(reqs, reqs + 2); + std::cout << msg << "!" << std::endl; + } else { + mpi::request reqs[2]; + std::string msg, out_msg = "world"; + reqs[0] = world.isend(0, 1, out_msg); + reqs[1] = world.irecv(0, 0, msg); + mpi::wait_all(reqs, reqs + 2); + std::cout << msg << ", "; + } + + return 0; +} |