正文

java多线程

小六 /13 浏览量
0514

在Java中，确保多线程按顺序执行可以通过以下几种方法实现：

使用`join（）`方法

通过调用线程的`join（）`方法，可以确保当前线程等待前一个线程执行完毕后，再继续执行。

 Thread thread1 = new Thread（new Runnable（） { @Override public void run（） { System.out.println（"打开冰箱!"）； } }）； Thread thread2 = new Thread（new Runnable（） { @Override public void run（） { try { thread1.join（）； } catch （InterruptedException e） { e.printStackTrace（）； } System.out.println（"拿出一瓶牛奶!"）； } }）； thread1.start（）； thread2.start（）；

使用`CountDownLatch`

`CountDownLatch`允许一个或多个线程等待其他线程完成操作。

 final CountDownLatch latch = new CountDownLatch（1）； new Thread（new Runnable（） { @Override public void run（） { System.out.println（"打开冰箱!"）； latch.countDown（）； } }）.start（）； new Thread（new Runnable（） { @Override public void run（） { try { latch.await（）； } catch （InterruptedException e） { e.printStackTrace（）； } System.out.println（"拿出一瓶牛奶!"）； } }）.start（）；

使用`Semaphore`信号量

`Semaphore`可以用来控制同时访问某一资源的线程数量，通过信号量的许可机制，可以确保线程按顺序执行。

 Semaphore semaphore = new Semaphore（1）； new Thread（new Runnable（） { @Override public void run（） { try { semaphore.acquire（）； System.out.println（"打开冰箱!"）； } catch （InterruptedException e） { e.printStackTrace（）； } finally { semaphore.release（）； } } }）.start（）； new Thread（new Runnable（） { @Override public void run（） { try { semaphore.acquire（）； System.out.println（"拿出一瓶牛奶!"）； } catch （InterruptedException e） { e.printStackTrace（）； } finally { semaphore.release（）； } } }）.start（）；

使用`BlockingQueue`

`BlockingQueue`提供了线程安全的队列，可以用于线程间的协调，确保按顺序执行任务。

 BlockingQueue 
  
    
  
    queue = new LinkedBlockingQueue<>（）； 
   new Thread（new Runnable（） { @Override public void run（） { try { queue.put（"打开冰箱!"）； } catch （InterruptedException e） { e.printStackTrace（）； } } }）.start（）； new Thread（new Runnable（） { @Override public void run（） { try { System.out.println（queue.take（））； } catch （InterruptedException e） { e.printStackTrace（）； } System.out.println（"拿出一瓶牛奶!"）； } }）.start（）；

使用`Lock`和`Condition`

`Lock`和`Condition`提供了比`synchronized`更灵活的线程同步机制，可以控制线程在特定条件下的等待或唤醒。

 private final Lock lock = new ReentrantLock（）； private final Condition condition = lock.newCondition（）； new Thread（new Runnable（） { @Override public void run（） { lock.lock（）； try { System.out.println（"打开冰箱!"）； condition.await（）； } catch （InterruptedException e） { e.printStackTrace（）； } finally { lock.unlock（）； } } }）.start（）； new Thread（new Runnable（） { @Override public void run（） { lock.lock（）； try { System.out.println（"拿出一瓶牛奶!"）； condition.signal（）； } finally { lock.unlock（）； } } }）.start（）；

使用`CyclicBarrier`

`CyclicBarrier`可以让一组线程等待至某种状态后全部执行

-- 展开阅读全文 --