WinHPC ppt

Size: px

Start display at page:

Download "WinHPC ppt"

けいしょうとりこし
5 years ago
Views:

1 MPI.NET C#

2 MPI.NET MPI.NET C#

3 MPI.NET C# MPI MPI.NET 1 1 MPI.NET C# Hello World

4 MPI.NET.NET Framework.NET C# API

5 C# Microsoft.NET java.net (Visual Basic.NET Visual C++)

$// { // System.Console.Write( Hello World\n ); } }$

6 C# class Helloworld // { public static void Main() // { // System.Console.Write( Hello World\n ); } }

7 MPI Message Passing Interface MPI MPI-1 MPI-2 2 MPI.NET MPICH MPICH2 LAM/MPI MS-MPI Ver NET C# C, C++, fortran

8 MPI 1 1 ID

9 1 if else

10 C# Visual Studio 2008 Visual C# 2008 Express Edition.NET.NET Framework 3.5 MPI.NET MPI.NET SDK 1.0 OS Windows HPC Server 2008 HPC Pack 2008 SDK Microsoft Compute Cluster Server 2003 Microsoft Compute Cluster Pack SDK

11 MPI.NET 1 1 Send Receive ImmediateSend ImmediateReceive Barrier Gather Broadcast Reduce

12 Send Receive ImmediateSend ImmediateReceive

13 Send public void Send<T>(value, dest, tag) value dest tag int if (comm.rank == 0) { string value = Windows ; comm.send(value, 1, 9); }

14 Receive public T Receive<T>(source, tag) source tag int if (comm.rank == 0) { string value = Windows ; comm.send(value, 1, 9); } else if(comm.rank == 1) { string msg = comm.receive<string>(0, 9); } Console.Write(msg);

15 (1/2) 1. Visual Studio > ->

16 (2/2) Message Passing Interface

17 1 1 (1/2) HelloWorld 0 1 using System; using MPI; // MPI class Helloworld { static void Main(string[] args) { // MPI using (new MPI.Environment(ref args)) { MPI } } }

18 1 1 (2/2) // Intracommunicator comm = Communicator.world; int tag = 9; // if (comm.rank == 0) { comm.send( HelloWorld, 1, tag); // 1 } else if(comm.rank == 1) { string msg = comm.receive<string>(0, tag); // 0 Console.Write(msg); }

19 & Shift + F6 -> PowerShell > job submit /scheduler:( ) /numcores:( ) /workdir:( ) mpiexec ( )

20 C mpich (1/2) #include <stdio.h> #include <string.h> #include <mpi.h> // using MPI int main(int argc, char *argv[]) { char msg[20]; // int rank; // int tag = 9; // new MPI.Environment(ref args) MPI_Init(&argc, &argv); MPI_Comm_rank(MPI_COMM_WORLD, &rank);

21 C mpich (2/2) if (rank == 0) { sprintf(msg, HelloWorld ); MPI_Send(msg, strlen(msg), MPI_CHAR, 1, tag, MPI_COMM_WORLD); } else if(rank == 1) { MPI_Status status; MPI_Recv(msg, 20, MPI_CHAR, 0, tag, MPI_COMM_WORLD, &status); } } printf( %s\n, msg); MPI_Finalize(); return 0;

22 MPI.NET mpich MPI.NET comm.send(value, dest, tag) 3 4 mpich MPI_Send(void *msg, int count, MPI_Datatype datatype, int dest, int tag, MPI_COMM comm) msg count MPI_Datatype dest tag comm 6

23 for(i=0; i<num; i++){ comm.send( HelloWorld, i, tag); } MPI one-to-all, all-to-one, all-to-all

24 : one to all public void Broadcast<T>(ref T value, root) 1 ref T value root root

25 : all to one public T[] Gather<T>(value, root) value root root

26 : Reduction( ) public T Reduce<T>(value, Operation, root) value Opration root root

27 (1/3) -1 1 = 4

28 (2/3) Reduce 3. 0 Reduce

29 (3/3) Random random = new Random(comm.Rank); // int num = 10000; // int count = 0; // for (int i = 0; i < num; ++i) { double x = (random.nextdouble() - 0.5) * 2; double y = (random.nextdouble() - 0.5) * 2; if (x * x + y * y <= 1.0) ++ count; } int total = comm.reduce(count, Operation<int>.Add, 0); if (comm.rank == 0) Pi = 4*(double) total/(comm.size*(double)num));

30 C# MPI.NET MPI.NET MPI.NET C#

31 MPI.NET( ) MPI.NET ation/reference/current/index.html

MPI MPI MPI.NET C# MPI Version2

MPI.NET C# 2 2009 2 27 MPI MPI MPI.NET C# MPI Version2 MPI (Message Passing Interface) MPI MPI Version 1 1994 1 1 1 1 ID MPI MPI_Send MPI_Recv if(rank == 0){ // 0 MPI_Send(); } else if(rank == 1){ // 1