浅谈一下Java的线程并发

public class ThreadTest {

    public static class MyThread extends Thread {

        @Override
        public void run() {
            System.out.println("This is a thread");
        }
    }

    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        myThread.start();
    }
}

public class RunnableTest implements Runnable {

    @Override
    public void run() {
        System.out.println("Runnable!");
    }

    public static void main(String[] args) {
        RunnableTest runnableTest = new RunnableTest();
        new Thread(runnableTest).start();
    }
}

public class CallableTest implements Callable<String> {

    @Override
    public String call() throws Exception {
        return "Callable!";
    }

    public static void main(String[] args) {
        FutureTask<String> futureTask = new FutureTask<>(new CallableTest());
        new Thread(futureTask).start();
        try {
            String result = futureTask.get();
            System.out.println(result);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }
}

public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch = new CountDownLatch(5);

        Thread DaQiao = new Thread(countDownLatch::countDown);
        Thread LanLingWang = new Thread(countDownLatch::countDown);
        Thread AnQiLa = new Thread(countDownLatch::countDown);
        Thread NeZha = new Thread(countDownLatch::countDown);
        Thread Kai = new Thread(() -> {
            try {
                // 稍等，上个卫生间，马上到...
                Thread.sleep(1500);
                countDownLatch.countDown();
            } catch (InterruptedException ignored) {}
        });

        DaQiao.start();
        LanLingWang.start();
        AnQiLa.start();
        NeZha.start();
        Kai.start();
        countDownLatch.await();
        System.out.println("所有玩家已经就位！");
    }