实战难题：多线程并发控制Java实例

原创拼搏现实的明天。 2024-10-15 03:36 61阅读 0赞

在Java中，多线程并发控制是通过synchronized关键字、wait/notify机制以及Lock接口实现的。以下是一个简单的多线程并发控制的Java实例：

```java
// 创建一个共享资源（这里我们用一个整数）
private int sharedResource = 0;

// 第一个线程，用于增加资源
public class AddThread implements Runnable {
    @Override
    public void run() {
        // 获取锁
        synchronized (sharedResource) {
            // 如果资源足够，就增加它
            if (sharedResource < 10) {
                sharedResource++;
                System.out.println("AddThread: Resource added to " + sharedResource);
            } else {
                System.out.println("AddThread: Resource limit reached, cannot add more.");
            }
        }
    }
}

// 第二个线程，用于检查资源
public class CheckThread implements Runnable {
    @Override
    public void run() {
        // 获取锁
        synchronized (sharedResource) {
            System.out.println("CheckThread: Checking resource at " + sharedResource);
            // 如果资源已经增加到10以上，则表示成功检查
            if (sharedResource > 10) {
                System.out.println("CheckThread: Resource successfully checked, now at " + sharedResource);
            } else {
                System.out.println("CheckThread: Resource check failed, resource is currently at " + sharedResource);
            }
        }
    }
}

// 创建并启动线程
public class Main {
    public static void main(String[] args) {
        // 创建线程对象
        AddThread addThread = new AddThread();
        CheckThread checkThread = new CheckThread();

// 启动线程
        Thread threadAdd = new Thread(addThread);
        Thread threadCheck = new Thread(checkThread);

threadAdd.start();    // 添加资源的线程
        threadCheck.start();   // 检查资源的线程

try {
            // 主线程等待所有子线程执行完毕
            threadAdd.join();
            threadCheck.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

这个例子中，我们创建了两个线程（一个用于增加资源，另一个用于检查资源）来演示多线程并发控制。