“多线程交替打印”的版本间的差异
跳到导航
跳到搜索
Jihongchang(讨论 | 贡献) |
Jihongchang(讨论 | 贡献) |
||
第1行: | 第1行: | ||
https://www.bilibili.com/video/BV1ez421C7Fz/?spm_id_from=333.999.0.0&vd_source=92b1acbb084e38873b05857f8f1b9289 | https://www.bilibili.com/video/BV1ez421C7Fz/?spm_id_from=333.999.0.0&vd_source=92b1acbb084e38873b05857f8f1b9289 | ||
− | 有两个线程,分别打印a字符和b字符 | + | 有两个线程,分别打印a字符和b字符<syntaxhighlight lang="java"> |
+ | package basic; | ||
+ | |||
+ | import java.util.concurrent.atomic.AtomicInteger; | ||
+ | |||
+ | public class MultiPrint2 { | ||
+ | |||
+ | public static void main(String[] args) throws InterruptedException { | ||
+ | Object monitor = new Object(); | ||
+ | AtomicInteger i = new AtomicInteger(0); | ||
+ | PrintRunnable pr = new PrintRunnable(monitor, i, 100); | ||
+ | Thread t1 = new Thread(pr); | ||
+ | Thread t2 = new Thread(pr); | ||
+ | t1.start(); | ||
+ | t2.start(); | ||
+ | //得t1和t2都执行完才能结束 | ||
+ | t1.join(); | ||
+ | System.out.println(t1.getId() + "结束"); | ||
+ | //得t1和t2都执行完才能结束 | ||
+ | t2.join(); | ||
+ | System.out.println(t2.getId() + "结束"); | ||
+ | } | ||
+ | } | ||
+ | |||
+ | class PrintRunnable implements Runnable { | ||
+ | private Object monitor; | ||
+ | private AtomicInteger i; | ||
+ | private int end; | ||
+ | /** | ||
+ | * @param monitor | ||
+ | * @param i | ||
+ | * @param end | ||
+ | */ | ||
+ | public PrintRunnable(Object monitor, AtomicInteger i, int end) { | ||
+ | super(); | ||
+ | this.monitor = monitor; | ||
+ | this.i = i; | ||
+ | this.end = end; | ||
+ | } | ||
+ | @Override | ||
+ | public void run() { | ||
+ | long id = Thread.currentThread().getId(); | ||
+ | synchronized (monitor) { | ||
+ | while (i.get() < end) { | ||
+ | System.out.println(id + ":" + i.incrementAndGet()); | ||
+ | try { | ||
+ | monitor.notify(); | ||
+ | monitor.wait(); | ||
+ | } catch (InterruptedException e) { | ||
+ | e.printStackTrace(); | ||
+ | } | ||
+ | /** | ||
+ | * notify要在synchronized里,不然会抛IllegalMonitorStateException | ||
+ | * 这单独的一个notify调用是为了通知另一个还在while里wait的线程 | ||
+ | */ | ||
+ | monitor.notify(); | ||
+ | } | ||
+ | } | ||
+ | } | ||
+ | } | ||
+ | |||
+ | </syntaxhighlight> |
2024年7月6日 (六) 12:22的版本
有两个线程,分别打印a字符和b字符
package basic;
import java.util.concurrent.atomic.AtomicInteger;
public class MultiPrint2 {
public static void main(String[] args) throws InterruptedException {
Object monitor = new Object();
AtomicInteger i = new AtomicInteger(0);
PrintRunnable pr = new PrintRunnable(monitor, i, 100);
Thread t1 = new Thread(pr);
Thread t2 = new Thread(pr);
t1.start();
t2.start();
//得t1和t2都执行完才能结束
t1.join();
System.out.println(t1.getId() + "结束");
//得t1和t2都执行完才能结束
t2.join();
System.out.println(t2.getId() + "结束");
}
}
class PrintRunnable implements Runnable {
private Object monitor;
private AtomicInteger i;
private int end;
/**
* @param monitor
* @param i
* @param end
*/
public PrintRunnable(Object monitor, AtomicInteger i, int end) {
super();
this.monitor = monitor;
this.i = i;
this.end = end;
}
@Override
public void run() {
long id = Thread.currentThread().getId();
synchronized (monitor) {
while (i.get() < end) {
System.out.println(id + ":" + i.incrementAndGet());
try {
monitor.notify();
monitor.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
/**
* notify要在synchronized里,不然会抛IllegalMonitorStateException
* 这单独的一个notify调用是为了通知另一个还在while里wait的线程
*/
monitor.notify();
}
}
}
}