import com.hydra.core.job.Job;
import com.hydra.core.job.JobContext;
import com.hydra.core.worker.Worker;
import com.hydra.core.worker.WorkerPool;
public class MyJob implements Job {
@Override
public void execute(JobContext context) {
System.out.println("Executing job: " + context.getJobId());
}
}
public class Main {
public static void main(String[] args) {
WorkerPool workerPool = new WorkerPool();
Worker worker1 = new Worker("worker1");
Worker worker2 = new Worker("worker2");
workerPool.addWorker(worker1);
workerPool.addWorker(worker2);
Job job = new MyJob();
workerPool.submitJob(job);
workerPool.shutdown();
}
}
