1 |
mojays |
2 |
package appl.parallel.thread; |
2 |
|
|
|
3 |
|
|
import appl.parallel.ComputingResourceProperties; |
4 |
|
|
import appl.parallel.event.CommEventSink; |
5 |
|
|
import appl.parallel.event.CommEvent.CommType; |
6 |
|
|
import appl.parallel.server.PartitionDataServer; |
7 |
|
|
|
8 |
|
|
/** |
9 |
|
|
* @author Dominik Appl |
10 |
|
|
*/ |
11 |
|
|
public abstract class DataServerThread extends ExecutionThread { |
12 |
|
|
|
13 |
|
|
public DataServerThread(PartitionDataServer dataServer,ComputingResourceProperties resourceInfos, Object argument,CommType type, CommEventSink sink){ |
14 |
|
|
super(dataServer,resourceInfos,argument,type,sink,false); |
15 |
|
|
} |
16 |
|
|
|
17 |
|
|
public DataServerThread(PartitionDataServer dataServer,ComputingResourceProperties resourceInfos, Object argument,CommType type, CommEventSink sink, boolean disableTransferEvents){ |
18 |
|
|
super(dataServer,resourceInfos,argument,type,sink,disableTransferEvents); |
19 |
|
|
} |
20 |
|
|
|
21 |
|
|
protected PartitionDataServer getServer(){ |
22 |
|
|
return (PartitionDataServer) server; |
23 |
|
|
} |
24 |
|
|
|
25 |
|
|
} |