java中的executor服务不是并行提交任务的吗？

Question

我在玩java多线程代码。我创建了一个具有固定线程池的executor服务。我正在提交两个任务顺序。我试图用线程使第一个任务变得很长。我在想这两个任务将并行运行。然而，当我运行程序时，程序会等待一段时间，然后输出一个B，这意味着编译器首先完成了第一个任务，然后才执行第二个任务。事实上，我在期待，因为第二个任务是一个短任务，它会在第一个任务之前完成。有什么解释吗？

 public static void main(String[] args) {
    ExecutorService executor = Executors.newFixedThreadPool(10);
    Map<String, String> map = new HashMap<>();
    ReadWriteLock lock = new ReentrantReadWriteLock();
    executor.submit(() -> {
        lock.writeLock().lock();
        try {
            Thread.sleep(10000);
            map.put("boo", "mar");
            System.out.println("A");
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            lock.writeLock().unlock();
        }
    });

    executor.submit(() -> {
        lock.writeLock().lock();
        try {
            Thread.sleep(1);
            map.put("foo", "bar");
            System.out.println("B");
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            lock.writeLock().unlock();
        }
    });

    executor.shutdown();
}

Answer 1

在第一个线程Hibernate之前，您正在“锁定”writeLock。所以锁实际上是锁了10秒钟…然后就解锁了。第二个线程等待了10秒来获取锁。

事件顺序：

Thread 1: Starts
Thread 2: Starts

Thread 1: Acquire Lock and wait for 10 seconds.
Thread 2: Try to acquire lock (ends up waiting 10 seconds because it is already acquired by Thread 1).

Thread 1: Prints Data.
Thread 1: Unlocks lock.

Thread 2: Acquires lock.
Thread 2: Prints data.
Thread 2: Unlocks lock.

尝试如下所示（它只在必要时才获得锁。例如：在执行写操作或修改映射时）：

public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(10);
        Map<String, String> map = new HashMap<>();
        ReadWriteLock lock = new ReentrantReadWriteLock();
        executor.submit(() -> {
            try {
                Thread.sleep(10000);

                lock.writeLock().lock();
                map.put("boo", "mar");
                lock.writeLock().unlock();

                System.out.println("A");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        executor.submit(() -> {
            try {
                Thread.sleep(1);

                lock.writeLock().lock();
                map.put("foo", "bar");
                lock.writeLock().unlock();

                System.out.println("B");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        executor.shutdown();
    }