阅读量:0
在Java中，可以通过以下几种方式实现多线程同步：
- 使用synchronized关键字：
synchronized关键字可以用于修饰方法或者代码块，当一个线程访问被synchronized修饰的方法或代码块时，其他线程将无法访问该方法或代码块。这样可以确保同一时间只有一个线程能够访问共享资源。
示例：
public class SynchronizedExample { public static void main(String[] args) { Counter counter = new Counter(); Thread t1 = new Thread(new Runnable() { @Override public void run() { for (int i = 0; i < 1000; i++) { counter.increase(); } } }); Thread t2 = new Thread(new Runnable() { @Override public void run() { for (int i = 0; i < 1000; i++) { counter.increase(); } } }); t1.start(); t2.start(); try { t1.join(); t2.join(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("Counter: " + counter.getCount()); } } class Counter { private int count; public synchronized void increase() { count++; } public synchronized int getCount() { return count; } } - 使用Lock接口和ReentrantLock类：
Java提供了Lock接口和ReentrantLock类来实现更灵活的线程同步。与synchronized相比，Lock提供了更高的灵活性，例如可以尝试获取锁、定时获取锁和可中断获取锁等操作。
示例：
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class LockExample { public static void main(String[] args) { Counter counter = new Counter(); Thread t1 = new Thread(new Runnable() { @Override public void run() { for (int i = 0; i < 1000; i++) { counter.increase(); } } }); Thread t2 = new Thread(new Runnable() { @Override public void run() { for (int i = 0; i < 1000; i++) { counter.increase(); } } }); t1.start(); t2.start(); try { t1.join(); t2.join(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("Counter: " + counter.getCount()); } } class Counter { private int count; private Lock lock = new ReentrantLock(); public void increase() { lock.lock(); try { count++; } finally { lock.unlock(); } } public int getCount() { lock.lock(); try { return count; } finally { lock.unlock(); } } } - 使用java.util.concurrent包中的高级同步工具：
Java提供了许多高级的同步工具，如Semaphore、CountDownLatch、CyclicBarrier等。这些工具可以帮助您更容易地实现复杂的多线程同步需求。
示例（使用CountDownLatch）：
import java.util.concurrent.CountDownLatch; public class CountDownLatchExample { public static void main(String[] args) { Counter counter = new Counter(); CountDownLatch latch = new CountDownLatch(2); Thread t1 = new Thread(new Runnable() { @Override public void run() { for (int i = 0; i < 1000; i++) { counter.increase(); } latch.countDown(); } }); Thread t2 = new Thread(new Runnable() { @Override public void run() { for (int i = 0; i < 1000; i++) { counter.increase(); } latch.countDown(); } }); t1.start(); t2.start(); try { latch.await(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("Counter: " + counter.getCount()); } } class Counter { private int count; public synchronized void increase() { count++; } public synchronized int getCount() { return count; } } 以上就是Java中实现多线程同步的几种方法。在实际应用中，可以根据具体需求选择合适的同步方式。
