当前位置：首页 > news >正文

【Java ee 初阶】多线程（9）上

news 来源：原创 2025/5/22 10:09:24

一、信号量Semaphore

本质上就是一个计数器，描述了一种“可用资源”的个数

申请资源（P操作）：使得计数器-1

释放资源（V操作）：使得计数器+1

如果计数器为0了，继续申请资源，就会触发阻塞

上述+1 -1 这些操作，都是原子的

Java把操作系统提供的信号量进行封装

package Thread;import java.util.concurrent.Semaphore;public class demo4 {public static void main(String[] args) throws InterruptedException {Semaphore semaphore = new Semaphore(3);semaphore.acquire();System.out.println("执行P操作");semaphore.acquire();System.out.println("执行P操作");semaphore.acquire();System.out.println("执行P操作");semaphore.acquire();System.out.println("执行P操作");}
}

最后输出：

package Thread;import java.util.concurrent.Semaphore;public class demo4 {public static void main(String[] args) throws InterruptedException {Semaphore semaphore = new Semaphore(3);semaphore.acquire();System.out.println("执行P操作");semaphore.release();System.out.println("执行V操作");}
}

输出：

通过信号量来实现原子操作：

package Thread;import java.util.concurrent.Semaphore;public class demo5 {
private static int count = 0;
public static void main(String[] args) throws InterruptedException {Semaphore semaphore = new Semaphore(1);Thread t1 = new Thread(()->{for(int i=0;i<5000;i++){try {semaphore.acquire();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}count++;semaphore.release();}  });Thread t2 = new Thread(()->{for(int i=0;i<5000;i++){try {semaphore.acquire();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}count++;semaphore.release();}});t1.start();t2.start();t1.join(); t2.join();System.out.println(count);
}
}

输出：

信号量，相当于“锁”概念的进一步延申。锁，可以视为是“初始值为1”的特殊信号量。

小结：编写线程安全代码的时候：

1.加锁（最主要）

2.CAS/原子类

3.信号量

package Thread;import java.util.concurrent.CountDownLatch;public class demo6 {public static void main(String[] args) throws InterruptedException {CountDownLatch latch = new CountDownLatch(8);for(int i=0;i<8;i++){int id =i;Thread t = new Thread(()->{try {Thread.sleep(1000);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}System.out.println("线程"+id+"执行完毕");latch.countDown();//计数器减1});t.start();}//主线程通过await等待所有线程执行完毕//awaur阻塞，直到countDownLatch调用latch.countDown()减为0latch.await();}}

二、多线程环境使用ArrayList

三、多线程环境使用哈希表

HashMap线程不安全

解决方案：

1）自己加锁

2）Hashtable类似于Vector，在关键方法加了synchronized

package Thread;import java.util.Hashtable;public class demo7 {public static void main(String[] args) {Hashtable<String,String> hashtable = new Hashtable<>();hashtable.put("k1", "v1");hashtable.put("k2", "v2");hashtable.put("k3", "v3");hashtable.get("v1");}
}