public class Main {

    private static final String TEXT = "abcdefghijklmnopqrstuvwxyz";
    
    public static void main(String[] args) throws Exception {
        byte[] bytes = TEXT.getBytes();
        File[] files = { new File("output1.txt"), new File("output2.txt") };
        CyclicBarrier cyclicBarrier = new CyclicBarrier(files.length + 1);
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (File file : files) {
            executorService.submit(new ICallable(cyclicBarrier, file, bytes));
        }
        executorService.shutdown();
        cyclicBarrier.await();
        System.out.println("END");
    }
}

class ICallable implements Callable<Object> {

    private CyclicBarrier cyclicBarrier;
    private File file;
    private byte[] bytes;

    public ICallable(CyclicBarrier cyclicBarrier, File file, byte[] bytes) {
        this.cyclicBarrier = cyclicBarrier;
        this.file = file;
        this.bytes = bytes;
    }

    public Object call() throws Exception {
        BufferedOutputStream bufferedOutputStream = null;
        try {
            bufferedOutputStream = new BufferedOutputStream(new FileOutputStream(file));
            bufferedOutputStream.write(bytes);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (bufferedOutputStream != null) {
                bufferedOutputStream.close();
            }
            cyclicBarrier.await();
        }
        return null;
    }

}