Package no.uib.cipr.matrix.distributed
Class Communicator
java.lang.Object
no.uib.cipr.matrix.distributed.Communicator
Deprecated.
Inter-thread communications. Supports point-to-point communications using
barriers between the threads. Construct it using the
CollectiveCommunications.createCommunicator
method.
All Object
s which are sent and recieved are arrays (for
instance, double[]
or int[]
), and the types
must be compatible. It follows that Object[]
is an array of
native arrays, such as int[][]
.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Deprecated.Gathers data from all tasks and distribute it to all.void
Deprecated.Combines values from all processes and distribute the result back to all processes.void
Deprecated.Sends data from all to all processes.void
Deprecated.Waits for the given asynchronous operation to finishvoid
Deprecated.Waits for the given asynchronous operations to finishvoid
barrier()
Deprecated.Blocks until all process have reached this routine.void
Deprecated.Broadcasts a message from the process with rank "root" to all other processes of the group.void
Deprecated.Gathers together values from a group of processes.Deprecated.Deprecated.Deprecated.Deprecated.int
rank()
Deprecated.Rank of this thread in the collectivevoid
Deprecated.void
Deprecated.Receives data[offset:offset+length] from peervoid
Deprecated.Reduces values on all processes to a single valuevoid
Deprecated.Sends data from one task to all other tasks in a group.void
Deprecated.void
Deprecated.Sends data[offset:offset+length] to peerint
size()
Deprecated.Size of the collective
-
Method Details
-
rank
public int rank()Deprecated.Rank of this thread in the collective -
size
public int size()Deprecated.Size of the collective -
allGather
Deprecated.Gathers data from all tasks and distribute it to all.Row corresponds to ranks, and columns corresponds to data.
Input:
A1 B1 C1 D1 Output:
A1 B1 C1 D1 A1 B1 C1 D1 A1 B1 C1 D1 A1 B1 C1 D1 -
allReduce
Deprecated.Combines values from all processes and distribute the result back to all processes. -
allToAll
Deprecated.Sends data from all to all processes.Row corresponds to ranks, and columns corresponds to data.
Input:
A1 A2 A3 A4 B1 B2 B3 B4 C1 C2 C3 C4 D1 D2 D3 D4 Output:
A1 B1 C1 D1 A2 B2 C2 D2 A3 B3 C3 D3 A4 B4 C4 D4 -
barrier
public void barrier()Deprecated.Blocks until all process have reached this routine. -
broadcast
Deprecated.Broadcasts a message from the process with rank "root" to all other processes of the group.Row corresponds to ranks, and columns corresponds to data.
Input:
A1 Output:
A1 A1 A1 A1 -
gather
Deprecated.Gathers together values from a group of processes.Row corresponds to ranks, and columns corresponds to data.
Input:
A1 A2 A3 A4 Output:
A1 A2 A3 A4 -
reduce
Deprecated.Reduces values on all processes to a single value -
scatter
Deprecated.Sends data from one task to all other tasks in a group.Row corresponds to ranks, and columns corresponds to data.
Input:
A1 A2 A3 A4 Output:
A1 A2 A3 A4 -
send
Deprecated.Sends data[offset:offset+length] to peer -
recv
Deprecated.Receives data[offset:offset+length] from peer -
isend
Deprecated. -
irecv
Deprecated. -
send
Deprecated. -
recv
Deprecated. -
isend
Deprecated. -
irecv
Deprecated. -
await
Deprecated.Waits for the given asynchronous operations to finish -
await
Deprecated.Waits for the given asynchronous operation to finish
-
no.uib.cipr.matrix.distributed
package has been deprecated because of a number of hard to fix concurrency bugs. It is distributed only for backwards compatibility, but is not recommended. The utility of this package is questionable, as it does not allow distribution of computation between JVMs or across a network. For many people, distributed computing of multiple matrices can be achieved at a user-level through the JPPF Framework. Users who need to deal with few very large matrices may wish to implement their own storage classes and solvers using JPPF, but this will not be supported directly in matrix-toolkits-java.