PCJ is a library for Java language that helps to perform parallel and distributed calculations. The current version is able to work on the multicore systems connected with the typical interconnect such as ethernet or infiniband providing users with the uniform view across nodes.

Download PCJ library (jar file of 29.04.2017 ver. 5.0.6)  Latest (bug fixing release)!

Download PCJ manual (pdf) for PCJ 5 New!

The PCJ library can be used with no cost at BSD license. It requires Java 8 and no additional tools or comilers.  The PCJ library for Java 7 is available in the dowload section.

The source code is available at GitHub: https://github.com/hpdcj/pcj

Version 5.0.6 fixes some bugs occuring with the massive communication.

Version 5.0.3 contains support for Intel KNL chips.

Version 5 introduces asyncPut() and asyncGet() methods; put() and get() methods are now synchronous. There is new handling of shared variables. The code developed for PCJ 4 hast to be modified. For details please reffer to the JavaDoc file.

The usage should be acknowledged by reference to the PCJ web site and/or reference to the papers:

Usage of the PCJ:

Contact: bala@icm.edu.pl faramir@icm.edu.pl

Shared variables

The general rule is that variables are local to the tasks and cannot be accessed from another task.

PCJ offers possibility to mark some variables Shared using Java annotation mechanism. The Shared variables are accessible across tasks, eg. one task can get access to the shared variable instance stored in another task. Shared variables have to be defined as part of enum variable and have to be registered using @RegisterStorage annotation.

 

@RegisterStorage(ExampleGetPut.Shared.class)    // Register storage used by the class
public class ExampleGetPut implements StartPoint {

    @Storage(ExampleGetPut.class)     // Define storage
    enum Shared {
        a, array
    }

    public double a = PCJ.threadCount();
    public double array[] = new double[10];
 
[...]
}

The elements of Shared variable can be single variables, arrays as well as more complicated objects.

Access to a shared variables

The PCJ librrary provides methods to access shared variables, eg. to get value stored in the memory of another task ({\tt get()})or to modify variable located in the memory of another task (put()).

 

Both methods: get(} and put() perform one-sided communication. This means, that access to the memory of another task is performed only by task which executes get or put methods. The task which memory is contacted do not need to execute these methods.

 

The example code presents how to assign value of the variable a at task 3 to the variable c at task 0.

 

if (PCJ.myId()==0) c = (double) PCJ.get(3, Shared.a);

 

The same for assigning value of the variable array[2] at task 3 to the variable c at task 0.

 

if (PCJ.myId()==0) c = (double) PCJ.get(3, Shared.array, 3);

 

Next example presents how to assign value 3.0 to the variable a available at the task 5. This operation is performed by the task 0.

 

if (PCJ.myId()==0) PCJ.put(3.0, 5, Shared.a);

 

Simmilar, we send value of 4.0 to the array[] stored at the thask 2. The array[1] element is updated.

if (PCJ.myId()==0)PCJ.put(4.0, 2, Shared.array, 1);

 

The communication is performed in synchronous way. The asyncPut() and asyncGet() can be used for asynchronous communication which means that user has no guarantee that value has been changed or transferred from remote task. The use of asynchronous communication may cause some problems, especially for non experienced users. PCJ provides additional methods to solve this problem.