Modifier and Type | Method and Description |
---|---|
static Worker |
createWorker(InetSocketAddress masterAddress,
InetSocketAddress workerAddress,
int dataPort,
int selectorThreads,
int acceptQueueSizePerThreads,
int workerThreads,
String localFolder,
long spaceLimitBytes) |
static Worker |
createWorker(String masterAddress,
String workerAddress,
int dataPort,
int selectorThreads,
int acceptQueueSizePerThreads,
int workerThreads,
String localFolder,
long spaceLimitBytes) |
static void |
main(String[] args) |
void |
run() |
void |
start() |
void |
stop() |
public static Worker createWorker(InetSocketAddress masterAddress, InetSocketAddress workerAddress, int dataPort, int selectorThreads, int acceptQueueSizePerThreads, int workerThreads, String localFolder, long spaceLimitBytes)
public static Worker createWorker(String masterAddress, String workerAddress, int dataPort, int selectorThreads, int acceptQueueSizePerThreads, int workerThreads, String localFolder, long spaceLimitBytes)
public void start()
public void stop() throws IOException, InterruptedException
IOException
InterruptedException
public static void main(String[] args) throws UnknownHostException
UnknownHostException
Copyright © 2013. All rights reserved.