Class RemoteDistributedContext

java.lang.Object

org.episteme.core.distributed.RemoteDistributedContext

All Implemented Interfaces:

DistributedContext

public class RemoteDistributedContext
extends Object
implements DistributedContext

Remote implementation of DistributedContext (stub).

This class serves as a template/interface for future remote distributed computing implementations. Actual implementations could use:

• Java RMI for traditional remote method invocation
• gRPC for high-performance cross-language RPCs
• Apache Spark for large-scale data processing
• Hazelcast or GridGain for in-memory distributed computing

Serialization Requirements: Tasks submitted to this context MUST:

• Implement `Serializable` (enforced by API)
• Have all referenced classes/data serializable
• Not depend on non-serializable local state (e.g., ThreadLocal)

Math Context Propagation: The implementation should automatically capture the current `MathContext` when tasks are submitted and restore it on remote workers before execution.

Since:

1.0

Author:

Silvere Martin-Michiellot, Gemini AI (Google DeepMind)

Nested Class Summary

Nested classes/interfaces inherited from interface DistributedContext

DistributedContext.Priority

Constructor Summary

Constructors

Constructor	Description
RemoteDistributedContext(String[] remoteHosts, int port, boolean useEncryption)	Creates a remote distributed context.

Method Summary

Modifier and Type	Method	Description
int	getParallelism()	Returns the number of available processing nodes or cores.
<T extends Serializable> List<Future<T>>	invokeAll(List<Callable<T>> tasks)	Submits a collection of tasks for execution.
void	shutdown()	Shuts down the context.
<T extends Serializable> Future<T>	submit(Callable<T> task)	Submits a task for execution with NORMAL priority.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface DistributedContext

allGather, allGather, barrier, broadcast, broadcast, fence, get, get, put, put, submit

Constructor Details

RemoteDistributedContext

public RemoteDistributedContext(String[] remoteHosts,
 int port,
 boolean useEncryption)

Creates a remote distributed context.

Parameters:

remoteHosts - array of remote host addresses (e.g., ["192.168.1.10", "192.168.1.11"])

port - communication port

useEncryption - whether to use TLS/SSL encryption

Method Details

submit

public <T extends Serializable> Future<T> submit(Callable<T> task)

Description copied from interface: DistributedContext

Submits a task for execution with NORMAL priority.

Specified by:

submit in interface DistributedContext

Type Parameters:

T - Result type

Parameters:

task - Task to execute

Returns:

Future representing the result

invokeAll

public <T extends Serializable> List<Future<T>> invokeAll(List<Callable<T>> tasks)

Description copied from interface: DistributedContext

Submits a collection of tasks for execution.

Specified by:

invokeAll in interface DistributedContext

Type Parameters:

T - Result type

Parameters:

tasks - List of tasks

Returns:

List of Futures

getParallelism

public int getParallelism()

Description copied from interface: DistributedContext

Returns the number of available processing nodes or cores.

Specified by:

getParallelism in interface DistributedContext

shutdown

public void shutdown()

Description copied from interface: DistributedContext

Shuts down the context.

Specified by:

shutdown in interface DistributedContext