Java Executors

java-executors.md

        Callable r = () -> {
            try {
                log.debug("TryLock");
                readLock.tryLock(5, TimeUnit.SECONDS);
                Thread.sleep(1000);
                log.debug("Read");
                readLock.unlock();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return null;
        };
        Callable w = () -> {
            try {
                log.debug("TryLock");
                writeLock.tryLock(5, TimeUnit.SECONDS);
                Thread.sleep(1000);
                log.debug("Write");
                writeLock.unlock();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return null;
        };

        ExecutorService executor = Executors.newCachedThreadPool();

//        executor.submit(w);
//        executor.submit(r);
//        executor.submit(r);
//        executor.shutdown();
//        try {
//            executor.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
//        } catch (InterruptedException e) {
//            log.error(e.getMessage(),e);
//        }

        executor.invokeAll(Arrays.<Callable<Void>>asList(w,r,r));