cassia.util.parallel

Class BroadcastTools

cassia.util.parallel.BroadcastTools

public class BroadcastTools

This class offers some utility functions for broadcast and reduce operations. Some of the code is imported from PlaceGroup. This is currently a prototype implementation, under development.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BroadcastTools.SimpleWorkerPlaceGroup

Field Summary

Fields

Modifier and Type	Field and Description
static BroadcastTools.SimpleWorkerPlaceGroup	workers Field Type: cassia.util.parallel.BroadcastTools.SimpleWorkerPlaceGroup{self.min==1L, self!=null}

Constructor Summary

Constructors

Constructor and Description
BroadcastTools()

Method Summary

Modifier and Type	Method and Description
static <T> T	broadcastReduce(PlaceGroup pg, Reducible<T> reducer, Fun_0_0 <T> cl) Declaration: broadcastReduce[T](pg:PlaceGroup, reducer:Reducible[T], cl:()=>T):T.
static <T> T	broadcastReduceNest(PlaceGroup pg, Reducible<T> reducer, Fun_0_0 <T> cl) Declaration: broadcastReduceNest[T](pg:PlaceGroup, reducer:Reducible[T], cl:()=>T):T.

Field Detail

workers

public static final BroadcastTools.SimpleWorkerPlaceGroup workers

Field Type: cassia.util.parallel.BroadcastTools.SimpleWorkerPlaceGroup{self.min==1L, self!=null}

Constructor Detail

BroadcastTools

public BroadcastTools()

Method Detail

broadcastReduce

public static <T> T broadcastReduce(PlaceGroup pg,
                                    Reducible<T> reducer,
                                    Fun_0_0 <T> cl)

Declaration: broadcastReduce[T](pg:PlaceGroup, reducer:Reducible[T], cl:()=>T):T.

broadcastReduceNest

public static <T> T broadcastReduceNest(PlaceGroup pg,
                                        Reducible<T> reducer,
                                        Fun_0_0 <T> cl)

Declaration: broadcastReduceNest[T](pg:PlaceGroup, reducer:Reducible[T], cl:()=>T):T.