并发控制问题：Java线程同步与互斥示例

原创小灰灰 2024-10-11 19:45 56阅读 0赞

在Java中，线程的同步和互斥是通过synchronized关键字实现的。以下是一个简单的示例：

1. **共享资源**（例如一个变量count）：
```java
public class SharedResource {
    private int count = 0;

// 同步方法：当只有一个线程访问该方法时，其他线程必须等待
    public synchronized void increment() {
        count++;
    }

// 返回当前的计数值
    public synchronized int getCount() {
        return count;
    }
}
```

2. **多线程同步示例**：
```java
public class ThreadSynchronizationExample {
    private SharedResource sharedResource = new SharedResource();

// 同步方法：当只有一个线程访问该方法时，其他线程必须等待
    public void incrementCount() {
        new Thread(() -> {
            try {
                sharedResource.increment();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
    }

public void printCount() {
        new Thread(() -> {
            try {
                while (!sharedResource.getCount().equals(0))) {
                    System.out.println("当前计数值: " + sharedResource.getCount());
                    Thread.sleep(1000); // 模拟耗时操作
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
    }

public static void main(String[] args) {
        ThreadSynchronizationExample example = new ThreadSynchronizationExample();

// 同步执行计数和打印操作
        new Thread(() -> {
            try {
                example.incrementCount();
                example.printCount();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        })).start();
    }
}
```

在上述示例中，我们创建了一个共享资源`SharedResource`。然后，在多线程环境下，我们将两个任务（`incrementCount`和`printCount`）放入同一个同步块中。

这样，当一个线程正在执行`incrementCount`时，其他线程必须等待该方法执行完毕后再执行。这就是Java中线程同步的基本原理。