import java.util.*;
import java.lang.*;
import java.io.*;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

class Ideone {
	public static void main (String[] args) throws java.lang.Exception {
		ExecutorService service =
                Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
        for (int i = 0; i < 10; i++) {
            service.submit(new Worker(new Object()));
        }
	}
}


class Worker implements Runnable {

    private Object factory;

    public Worker(Object factory) {
        this.factory = factory;
    }

    @Override
    public void run() {
        while (true) {
            Object o = factory.get();
            DataSender.send(o);
        }
    }
}