让一个程序同时做多件事,能够提高效率。
主要是当我想让多个功能同时运作的时候可以使用多线程。
举例: 放置游戏、某软件后台挂载更新、聊天软件、后台服务器…
Java处理线程相关的类
并发
概念上: 同一时刻,单个CPU执行多条指令的交替行为。
个人理解:一个人同时操作多个事件,快速、轮换、交替
进行。
并行
概念上:同一时刻,多个CPU执行多条指令
个人理解: 多个人同时操作多个事件,每个人都有分工 然后同时执行 (即:并在一起行动)
run
方法start()
启动线程 // 测试类:
MyThread m1 = new MyThread();
MyThread m2 = new MyThread();
m1.setName("线程1 ");
m2.setName("线程2 ");
m1.start();
m2.start();
public class MyThread extends Thread {
@Override
public void run() {
for (int i = 0; i < 100; i++) {
System.out.println(getName() + " HelloWorld!");
}
}
}
Runnable
接口,重写run()
start()
启动线程 MyRun myRun = new MyRun();
Thread t1 = new Thread(myRun);
Thread t2 = new Thread(myRun);
t1.setName("线程一: ");
t2.setName("线程二: ");
t1.start();
t2.start();
public class MyRun implements Runnable {
@Override
public void run() {
for (int i = 0; i < 100; i++) {
System.out.println(Thread.currentThread().getName() + "HelloThread!");
}
}
}
前面两种都没有返回值
Callable接口
,泛型是返回值类型,实现call
方法FutureTask<>
类 ( 用于管理获取返回值类型Thread
线程,开启线程FutureTask<>
对象的 get()
方法获取返回值 MyCallable myC = new MyCallable();
FutureTask<Integer> iFTask = new FutureTask<Integer>(myC);
Thread t1 = new Thread(iFTask);
t1.start();
Integer sum = iFTask.get();
System.out.println(sum);
public class MyCallable implements Callable<Integer> {
@Override
public Integer call() throws Exception {
int sum = 0;
for (int i = 1; i <= 100; i++) {
sum += i;
}
return sum;
}
}
需求:电影院卖票,共100张票,三个窗口卖。
没有加上同步代码块 会导致的问题:
同步代码块
方式避免以上问题: WicketThread w1 = new WicketThread("窗口一:");
WicketThread w2 = new WicketThread("窗口二:");
WicketThread w3 = new WicketThread("窗口三:");
w1.start();
w2.start();
w3.start();
public class WicketThread extends Thread {
public WicketThread() {
}
public WicketThread(String name) {
super(name);
}
// 这里使用的是实现线程方式一,会创建多个对象,所以需要static确定只有一个票仓
static int tickets = 0;
//锁对象 随意 , 但是一定要唯一
//不唯一会出现重复
//static Object obj = new Object();
@Override
public void run() {
while (true) {
//锁 同步代码块
synchronized (WicketThread.class) {
if (tickets < 100) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
tickets++;
System.out.println(getName() + "卖出第" + tickets + "张票");
} else {
break;
}
}
}
}
}
当我们需要把整个方法锁起来,就不需要使用同步代码块,而是直接加到方法定义上。
格式:
特点:
先写出同步代码块 然后提取代码块中的方法 在方法定义上加上synchronized即可
public class WicketRunnable implements Runnable {
//这里使用的是实现线程方式二,不会创建多个对象,所以不用static修饰也可以
int tickets = 0;
@Override
public void run() {
while (true) {
if (method()) break;
}
}
private synchronized boolean method() {
if (tickets == 100) {
return true;
} else {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
tickets++;
System.out.println(Thread.currentThread().getName() + "卖出第" + tickets + "张票");
}
return false;
}
}
使用同步锁 是属于 自动上锁 自动解锁,
但需要 手动设置 开关锁 的时候 使用 Lock
接口的ReentrantLock
实现类
void lock();
锁
void unlock()
解锁
public class WicketThread extends Thread {
public WicketThread() {
}
public WicketThread(String name) {
super(name);
}
static int tickets = 0;
//创建了多个线程对象,所以static修饰,只能有一个锁对象
static Lock lock = new ReentrantLock();
@Override
public void run() {
while (true) {
//synchronized (WicketThread.class) {
lock.lock();
try {
if (tickets < 100) {
Thread.sleep(100);
tickets++;
System.out.println(getName() + "卖出第" + tickets + "张票");
} else {
break;
}
} catch (InterruptedException e) {
throw new RuntimeException(e);
// 不管什么情况 finally 都会执行 也就是都会解锁
} finally {
lock.unlock();
}
//}
}
}
}
不同的线程分别占用对方的资源不放,都在等待对方放弃,就形成死锁。
出现死锁不会发生异常或提示,而且 处于线程阻塞状态 , 无法继续。
锁的嵌套会导致死锁,要避免。
线程具有随机性 所以使用等待唤醒机制 避免随机性
public class Customer extends Thread {
@Override
public void run() {
/*
* 1. 循环
* 2. 同步代码块/方法/lock
* 3. 判断结束条件
* 4. 判断没结束时候的执行(核心逻辑)
* */
while (true) {
synchronized (Desk.lock) {
if (Desk.count == 0) {
break;
} else {
if (Desk.productFlag == 0) {
//桌子上没东西,当前线程->消费者等待,生产者开做
try {
Desk.lock.wait();
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
} else {
//桌子有东西,开买
Desk.count--;
System.out.println("买了一个!当前还能再买" + Desk.count + "个");
//买完一个通知生产者
Desk.lock.notifyAll();
Desk.productFlag = 0;
}
}
}
}
}
}
public class Productor extends Thread {
@Override
public void run() {
while (true) {
synchronized (Desk.lock) {
if (Desk.count == 0) {
break;
} else {
//桌子上已有东西就等待
if (Desk.productFlag == 1) {
try {
Desk.lock.wait();
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
} else {
System.out.println("放桌上一个了");
Desk.productFlag = 1;
Desk.lock.notifyAll();
}
}
}
}
}
}
/**
* @Description: 生产者消费者 的 中转站
*/
public class Desk {
//判断桌子上是否有东西 0无,1有
static public int productFlag = 0;
//消费者只能买十个 限定条件
static public int count = 10;
//锁对象
final static public Object lock = new Object();
}
//测试main类
Productor p = new Productor();
Customer c = new Customer();
p.setName("生产者");
c.setName("消费者");
p.start();
c.start();
厨师生产食物给消费者(Consumer)
阻塞队列继承结构:
其实就是使用内部封装的方法实现消费者生产者模式,是队列的形式
使用ArrayBlockingQueue<>
中的 put()
take()
方法
举例put()
的源码:内部是用了lock锁 所以外部调用不用再写。take()
是一样的。
两个线程类通过构造接收 的是 同一个ArrayBlockingQueue对象
public class Cook extends Thread {
ArrayBlockingQueue<String> abq;
public Cook(ArrayBlockingQueue<String> abq) {
this.abq = abq;
}
@Override
public void run() {
while (true) {
try {
abq.put("食物"); // put
System.out.println("放一碗吃的");
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
}
public class Consumer extends Thread {
ArrayBlockingQueue<String> abq;
public Consumer(ArrayBlockingQueue<String> abq) {
this.abq = abq;
}
@Override
public void run() {
while (true) {
try {
String food = abq.take(); // take
System.out.println("消费者吃一碗" + food);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
}
//测试类
ArrayBlockingQueue<String> abq = new ArrayBlockingQueue<String>(1);
Cook cook = new Cook(abq);
Consumer consumer = new Consumer(abq);
cook.setName("厨师 ");
consumer.setName("消费者 ");
cook.start();
consumer.start();
打印的语句存在问题是因为:输出语句sout 在锁的外面,但是里面的数值是没有问题的。
Executors 工具类提供的静态方法:
ExecutorService es = Executors.newCachedThreadPool();
es.submit(new MyRunnable());
Thread.sleep(1000);
线程池原理:
类似C#对象池
需求:
? 假设:100块,分成了3个包,现在有5个人去抢。
? 其中,红包是共享数据。
? 5个人是5条线程。
? 打印结果如下:
? XXX抢到了XXX元
XXX没抢到…
方式一: Double
public class Person extends Thread {
static double money = 100;//总共100元
static int count = 3; // 分三个包抢
static final double MIN = 0.01;//最小红包
@Override
public void run() {
synchronized (Person.class) {
if(count == 0){
System.out.println(getName()+" 没抢到");
}else{
double prize = 0;
if(count == 1){
//最后一次
prize = money;
}else{
Random r = new Random();
//最极限的情况: 第一次 最多只能抢到99.98 , 第二次 第三次 为0.01
double bounds = money - (count - 1) * MIN;
prize = r.nextDouble(bounds);
if(prize < MIN){
prize = MIN;
}
}
money -= prize;
count--;
System.out.println(getName() + " 抢到 " + prize+" 元");
}
}
}
}
使用double 钱的数值会有问题。
方式二:BigDecimal
public class Person extends Thread {
static BigDecimal money = BigDecimal.valueOf(100);//总共100元
static int count = 3; // 分三个包抢
static final BigDecimal MIN = BigDecimal.valueOf(0.01);//最小红包
@Override
public void run() {
synchronized (Person.class) {
if (count == 0) {
System.out.println(getName() + " 没抢到");
} else {
BigDecimal prize;
if (count == 1) {
//最后一次
prize = money;
} else {
Random r = new Random();
//最极限的情况: 第一次 最多只能抢到99.98 , 第二次 第三次 为0.01
double bounds = money.subtract(BigDecimal.valueOf(count - 1)).multiply(MIN).doubleValue();
prize = BigDecimal.valueOf(r.nextDouble(bounds));
}
prize = prize.setScale(2, RoundingMode.HALF_UP);
money = money.subtract(prize);
count--;
System.out.println(getName() + " 抢到 " + prize + " 元");
}
}
}
}
需求:
抽奖池中的奖项为 : {10,5,20,50,100,200,500,800,2,80,300,700};
创建两个抽奖箱(线程)设置线程名称分别为“抽奖箱1”,“抽奖箱2”
随机从抽奖池中获取奖项元素并打印在控制台上,格式如下:
每次抽出一个奖项就打印一个(随机)
? 抽奖箱1 又产生了一个 10 元大奖
抽奖箱2 又产生了一个 500 元大奖 …
//测试类
ArrayList<Integer> list = new ArrayList<>();
Collections.addAll(list,10,5,20,50,100,200,500,800,2,80,300,700);
MyThread m1 = new MyThread(list);
MyThread m2 = new MyThread(list);
m1.setName("抽奖箱1");
m2.setName("抽奖箱2");
m1.start();
m2.start();
public class MyThread extends Thread {
ArrayList<Integer> list;
public MyThread(ArrayList<Integer> list) {
this.list = list;
}
@Override
public void run() {
while (true) {
synchronized (MyThread.class) {
if (list.size() == 0) {
break;
} else {
// 打乱集合,每次拿到集合的第一个数并且删除
Collections.shuffle(list);
Integer num = list.remove(0);
System.out.println(getName() + "抽到了" + num + " 元大奖");
}
}
//让结果均匀一点,写在锁的外面 让出来的线程休息10毫秒,让另一个线程进去
try {
Thread.sleep(10);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
}
需求:
? 在上一题基础上继续完成如下需求:
? 每次抽的过程中不打印,抽完时一次性打印(随机)
? 在此次抽奖过程中,抽奖箱1总共产生了6个奖项。
? 分别为:10,20,100,500,2,300最高奖项为300元,总计额为932元
? 在此次抽奖过程中,抽奖箱2总共产生了6个奖项。
? 分别为:5,50,200,800,80,700最高奖项为800元,总计额为1835元
public class MyThread extends Thread {
ArrayList<Integer> list;
int count = 0;//几个奖项
int sum = 0; //总和多少钱
int max = 0;
public MyThread(ArrayList<Integer> list) {
this.list = list;
}
@Override
public void run() {
ArrayList<Integer> newList = new ArrayList<Integer>();
while (true) {
synchronized (MyThread.class) {
if (list.size() == 0) {
System.out.println(getName() + "一共产生了" + count + "个奖项" + "分别是:" + newList + "总计额为" + sum + "元,"+"最大奖为"+max+"元");
break;
} else {
// 打乱集合,每次拿到集合的第一个数并且删除
Collections.shuffle(list);
Integer num = list.remove(0);
sum += num;
count++;
newList.add(num);
if(num > max){
max = num;
}
}
}
//让结果均匀一点,写在锁的外面 让出来的线程休息10毫秒,让另一个线程进去
try {
Thread.sleep(10);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
}
ArrayList<Integer> list = new ArrayList<>();
Collections.addAll(list,10,5,20,50,100,200,500,800,2,80,300,700);
MyThread m1 = new MyThread(list);
MyThread m2 = new MyThread(list);
m1.setName("抽奖箱1");
m2.setName("抽奖箱2");
m1.start();
m2.start();
在上一题基础上继续完成如下需求:
“在此次抽奖过程中,抽奖箱2中产生了最大奖项,该奖项金额为800元“”
对比两个线程之间的最大奖项。(也就是获取线程的结果)
public class MyCallable implements Callable<Integer> {
ArrayList<Integer> list;
int count = 0;//几个奖项
int sum = 0; //总和多少钱
int max = 0;
public MyCallable(ArrayList<Integer> list) {
this.list = list;
}
@Override
public Integer call() throws Exception {
ArrayList<Integer> newList = new ArrayList<Integer>();
while (true) {
synchronized (MyCallable.class) {
if (list.size() == 0) {
System.out.println(Thread.currentThread().getName() + "一共产生了" + count + "个奖项" + "分别是:"
+ newList + "总计额为" + sum + "元," + "最大奖为" + max + "元");
break;
} else {
// 打乱集合,每次拿到集合的第一个数并且删除
Collections.shuffle(list);
Integer num = list.remove(0);
sum += num;
count++;
newList.add(num);
max = Collections.max(newList);
}
}
//让结果均匀一点,写在锁的外面 让出来的线程休息10毫秒,让另一个线程进去
Thread.sleep(10);
}
if (newList.size() == 0) {
return null;
} else {
return max;
}
}
}
//测试类
ArrayList<Integer> list = new ArrayList<>();
Collections.addAll(list, 10, 5, 20, 50, 100, 200, 500, 800, 2, 80, 300, 700);
MyCallable mc1 = new MyCallable(list);
MyCallable mc2 = new MyCallable(list);
FutureTask<Integer> ift1 = new FutureTask<Integer>(mc1);
FutureTask<Integer> ift2 = new FutureTask<Integer>(mc2);
Thread t1 = new Thread(ift1);
Thread t2 = new Thread(ift2);
t1.setName("抽奖箱一:");
t2.setName("抽奖箱二:");
t1.start();
t2.start();
Integer max1 = ift1.get();
Integer max2 = ift2.get();
if(max1 > max2){
System.out.println(t1.getName()+"产生最大奖"+max1);
}else{
System.out.println(t2.getName()+"产生最大奖"+max2);
}
一个线程执行一段代码逻辑,多个线程就是执行多次同一段代码逻辑。