{"id":3102,"date":"2024-04-06T10:15:27","date_gmt":"2024-04-06T05:15:27","guid":{"rendered":"https:\/\/afzalbadshah.com\/?p=3102"},"modified":"2024-05-08T22:21:32","modified_gmt":"2024-05-08T17:21:32","slug":"mpi-concurrent-file-i-o-for-by-multiple-processes","status":"publish","type":"post","link":"https:\/\/afzalbadshah.com\/index.php\/2024\/04\/06\/mpi-concurrent-file-i-o-for-by-multiple-processes\/","title":{"rendered":"MPI: Concurrent File I\/O for by Multiple Processes"},"content":{"rendered":"\n

In this tutorial, we’ll explore an MPI (Message Passing Interface) program using mpi4py<\/code> to demonstrate how multiple processors can collectively write to and read from a shared file. The detailed tutorial of MPI with a python can be visited here.<\/a> <\/p>\n\n\n\n

Code<\/h3>\n\n\n\n
from mpi4py import MPI\n\n    comm = MPI.COMM_WORLD\n    rank = comm.Get_rank()\n    size = comm.Get_size()\n\n    # Define the file name\n    filename = \"output.txt\"\n\n    # Open the file in append mode and write a message from each processor\n    with open(filename, \"a\") as file:\n        file.write(f\"Hello from processor {rank} of {size}\\n\")\n\n    # Synchronize all processors before reading the file\n    comm.Barrier()\n\n    # Now let only one processor (e.g., rank 0) read and display the file content\n    if rank == 0:\n        # Open the file in read mode\n        with open(filename, \"r\") as file:\n            # Read and display the file content\n            print(\"File contents:\")\n            print(file.read())\n<\/code><\/pre>\n\n\n\n
\n