This is an old revision of the document!


This Wiki page is outdated, please go to:


The reduce_scatter functions operate elementwise on size sections of the buffer like data objects sendbuf. The sections must have the equal number of elements in all tasks. The result of the reductions in section i is copied to recvbuf in task i, which must have an appropriate length. The syntax for the reduction methods is

comm.Reduce_scatter_block(sendbuf, recvbuf, op=MPI.SUM)
comm.Reduce_scatter(sendbuf, recvbuf, recvcounts=None, op=MPI.SUM)

In Reduce_scatter_block the number of elements in all sections must be equal and the number of elements in sendbuf must be size times that number. An example code is the following


a_size = 3
recvdata = numpy.zeros(a_size,
senddata = (rank+1)*numpy.arange(size*a_size,
print 'on task',rank,'senddata  = ',senddata
print 'on task',rank,'recvdata = ',recvdata

In Reduce_scatter the number of elements in the sections can be different. They must be given in the integer tuple recvcounts. The number of elements in sendbuf must be sum of the numbers of elements in the sections. On task i recvbuf must have the length of section i of sendbuf. The following code gives an example for this.


recv_size = range(1,size+1)
recvdata = numpy.zeros(recv_size[rank],
send_size = 0
for i in  range(0,size):
   send_size =send_size + recv_size[i]
senddata = (rank+1)*numpy.arange(send_size,
print 'on task',rank,'senddata  = ',senddata
print 'on task',rank,'recvdata = ',recvdata

Reduction with MINLOC and MAXLOC

The reduction operations MINLOC and MAXLOC differ from all others: they return two results, the minimum resp. maximum of the values in the different tasks and the rank of a task, which holds the extreme value. mpi4py provides the two operations only for the lower case reduce and allreduce mehods for comparing a single numerical data object in every task. An example is given in

inp = numpy.random.rand(size)
senddata = inp[rank]
print 'on task',rank,'reduce:    ',senddata,recvdata 

print 'on task',rank,'allreduce: ',senddata,recvdata

Code Examples

The python codes for all examples described in this tutorial are available from

Scientific Computing

This website uses cookies. By using the website, you agree with storing cookies on your computer. Also you acknowledge that you have read and understand our Privacy Policy. If you do not agree leave the website.More information about cookies