第二章 线程完全与共享资源竞争
2.1 synchronized同步介绍
2.2 synchronized同步方法
static class Clock{
//定义私有变量
private int beginner;
//初始化
public Clock(int beginner){
this.beginner = beginner;
}
//定义timeout方法
public synchronized void timeout(){
//打印日志
System.out.println(Thread.currentThread().getName()+",进入....");
//自旋
while (this.beginner>0){
//自减
beginner--;
//打印日志
System.out.println(Thread.currentThread().getName()+",倒计时:"+beginner);
try {
//线程休眠1000
Thread.sleep(1000);
}catch (Exception e){
}
}
}
}
public static void main(String[] args) {
//初始化
Clock clock = new Clock(10);
//创建俩条线程
for (int i=0;i<2;i++){
new Thread(new Runnable() {
@Override
public void run() {
clock.timeout();
}
},"线程"+i).start();
}
}
- synchronized只能存在一条线程,排他得存在。
2.2.1 同步方法调用流程
- 同一个对象得synchronized方法之间是互斥的,即线程a调用了time方法,会阻碍线程b调用的timeout方法。
2.3 synchronized同步静态方法
2.4 synchronized同步代码块
- 在同步方法时,使用共享资源的只是部分代码。为了提高并发性能,一般没必要在整个方法的运行期都持有监视器锁。
static class TicketTask implements Runnable{
//定义私有变量
private Integer ticket = 30;
public void run(){
while (this.ticket>0){
//锁住当前对象
synchronized (this){
//预测还有票
if (ticket>0){
//打印日志
System.out.println(Thread.currentThread().getId()+"售出"+ticket);
ticket--;
}
}
//让其他线程执行
try {
Thread.sleep(100);
}catch (Exception e){
}
}
}
}
static class Curtain extends Thread{
//定义窗口编号
private String cno;
//获取编号
public String getCno(){
return cno;
}
//初始化
public Curtain(String cno,Runnable runnable){
//使用thread的初始化
super(runnable);
this.cno = cno;
}
}
public static void main(String[] args) {
TicketTask ticketTask = new TicketTask();
new Curtain("c01",ticketTask).start();
new Curtain("c02",ticketTask).start();
new Curtain("c03",ticketTask).start();
}
- 买票的操作
- thread.sleep代码放到同步块和同步块外差距比较大。同步块中,线程执行完之后,会再次去竞争锁,可能会出现所有任务被一个线程全部执行完的效果。不在同步块中,会产生短暂延迟,就不会和排队线程产生竞争关系,会出现多个线程交替执行的结果。