Java 개발: 멀티스레딩을 사용하여 동시 작업 처리를 구현하는 방법

public class MyThread extends Thread {
    public void run() {
        // 在这里写入线程运行时需要执行的代码
    }
}

// 创建并启动线程
MyThread myThread = new MyThread();
myThread.start();

public class MyRunnable implements Runnable {
    public void run() {
        // 在这里写入线程运行时需要执行的代码
    }
}

// 创建并启动线程
Thread thread = new Thread(new MyRunnable());
thread.start();

ExecutorService executorService = Executors.newFixedThreadPool(5); // 创建线程池，指定线程数量为5

for (int i = 0; i < 10; i++) {
    executorService.execute(new MyRunnable()); // 提交任务给线程池执行
}

executorService.shutdown(); // 关闭线程池

public class SharedData {
    private int count;

    public synchronized void increment() {
        count++;
    }

    public synchronized int getCount() {
        return count;
    }
}

SharedData sharedData = new SharedData();

// 创建并启动多个线程
for (int i = 0; i < 10; i++) {
    Thread thread = new Thread(() -> {
        sharedData.increment();
    });
    thread.start();
}

// 等待所有线程执行完毕
Thread.sleep(1000);

System.out.println(sharedData.getCount()); // 输出结果应为10

public class Message {
    private String content;
    private boolean isEmpty = true;

    public synchronized String take() {
        while (isEmpty) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        isEmpty = true;
        notifyAll();
        return content;
    }

    public synchronized void put(String content) {
        while (!isEmpty) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        isEmpty = false;
        this.content = content;
        notifyAll();
    }
}

Message message = new Message();

// 创建并启动多个线程
Thread producerThread = new Thread(() -> {
    for (int i = 0; i < 10; i++) {
        message.put("Message " + i);
        Thread.sleep(1000);
    }
});

Thread consumerThread = new Thread(() -> {
    for (int i = 0; i < 10; i++) {
        System.out.println(message.take());
        Thread.sleep(1000);
    }
});

producerThread.start();
consumerThread.start();

public class Counter {
    private int count = 0;

    public synchronized void increment() {
        count++;
    }

    public synchronized void decrement() {
        count--;
    }

    public synchronized int getCount() {
        return count;
    }
}

Counter counter = new Counter();

// 创建并启动多个线程
Thread incrementThread = new Thread(() -> {
    for (int i = 0; i < 1000; i++) {
        counter.increment();
    }
});

Thread decrementThread = new Thread(() -> {
    for (int i = 0; i < 1000; i++) {
        counter.decrement();
    }
});

incrementThread.start();
decrementThread.start();

incrementThread.join();
decrementThread.join();

System.out.println(counter.getCount()); // 输出结果应为0