<dependency> <groupId>com.scalop</groupId> <artifactId>scalop</artifactId> <version>1.0.0</version> </dependency> implementation 'com.scalop:scalop:1.0.0' import com.scalop.core.concurrent.Thread; public class MyConcurrentTask extends Thread { @Override public void run() { } } MyConcurrentTask task = new MyConcurrentTask(); task.start(); properties com.scalop.cluster.nodes=node1:9090,node2:9090,node3:9090 import com.scalop.core.distributed.ComputeNode; import com.scalop.core.distributed.DistributedTask; public class MyDistributedTask implements DistributedTask<String> { @Override public String execute(ComputeNode computeNode) { } } MyDistributedTask task = new MyDistributedTask(); String result = Scalop.executeDistributed(task); System.out.println(result);