Hi,
I add future variable for the rpc.rpc_async.
It worked. However, it is very slow.
It took around 30 minutes to finish this procedure.



 ph0123:

 for it in _local_dict:
            count = count+1
            arr_send = []
            for i in range(0, size):
                arr_send.append([])
            u = _local_dict[it]
            source = u.vertexId

            for i in u.links:
                arr_send[int(i) % size].append(int(i))
            futs = [] #add here
            for i in array_rpc:
                my_target = "worker" + str(i)
                if len(arr_send[i])>0:
                    futs.append(rpc.rpc_async(my_target, add_outlinks, args=(arr_send[i],source)))
            for fut in futs: #add here
                fut.wait() #add here



I try to put
 for fut in futs: #add here
                fut.wait() #add here

outside of the loop. The program is not finished and stopped by time out.
Could you explain why? and could you please suggest some ways to decrease the excuse time? I run the program with UPC++, it take some minutes to finish (~ 5-6 minutes)
Thanks