线程同步基础之使用非依赖属性实现同步

当使用synchronized关键字来保护代码块时,必须把对象引用作为传入参数。通常情况下,使用this关键字来引用执行方法所属的对象,也可以使用其他的对象对其进行引用。一般来说,这些对象就是为这个目的而创建的。例如,在类中有两个非依赖属性,它们被多个线程共享,你必须同步每一个变量的访问,但是同一时刻只允许一个线程访问一个属性变量,其他某个线程访问另一个属性变量。

这里我们演示电影院售票场景。这个范例模拟了有两个屏幕和两个售票处的电影院。一个集票处卖出的一张票,只能用于其中一个屏幕,不能同时用于两个屏幕,因此每个电影院的剩余票数是独立的属性。

示例:

packageconcurrency;

publicclassMain9{
publicstaticvoidmain(String[]args){
Cinemacinema=newCinema();
TicketOffice1ticketOffice1=newTicketOffice1(cinema);
Threadthread1=newThread(ticketOffice1,"TicketOffice1");
TicketOffice2ticketOffice2=newTicketOffice2(cinema);
Threadthread2=newThread(ticketOffice2,"TicketOffice2");
thread1.start();
thread2.start();
try{
//等待这两个线程结束!!
thread1.join();
thread1.join();
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.printf("Room1Vacancies:%d\n",cinema.getVacanciesCinema1());
System.out.printf("Room2Vacancies:%d\n",cinema.getVacanciesCinerna2());
}
}

//电影院类
classCinema{
privatelongvacanciesCinema1;
privatelongvacanciesCinema2;
privatefinalObjectcontrolCinema1,controlCinema2;
publicCinema(){
controlCinema1=newObject();
controlCinema2=newObject();
vacanciesCinema1=20;
vacanciesCinema2=20;
}
publicbooleansellTickets1(intnumber){
synchronized(controlCinema1){
if(number<vacanciesCinema1){
vacanciesCinema1-=number;
returntrue;
}else{
returnfalse;
}
}
}
publicbooleansellTickets2(intnumber){
synchronized(controlCinema2){
if(number<vacanciesCinema2){
vacanciesCinema2-=number;
returntrue;
}else{
returnfalse;
}
}
}
publicbooleanreturnTickets1(intnumber){
synchronized(controlCinema1){
vacanciesCinema1+=number;
returntrue;
}
}
publicbooleanreturnTickets2(intnumber){
synchronized(controlCinema2){
vacanciesCinema2+=number;
returntrue;
}
}
publiclonggetVacanciesCinema1(){
returnvacanciesCinema1;
}
publiclonggetVacanciesCinerna2(){
returnvacanciesCinema2;
}
}

//售票处1
classTicketOffice1implementsRunnable{
privateCinemacinema;
publicTicketOffice1(Cinemacinema){
this.cinema=cinema;
}
//模拟对电影院的操作
@Override
publicvoidrun(){
cinema.sellTickets1(3);
cinema.sellTickets1(2);
cinema.sellTickets2(2);
cinema.returnTickets1(3);
cinema.sellTickets1(5);
cinema.sellTickets2(2);
cinema.sellTickets2(2);
}
}

//售票处2
classTicketOffice2implementsRunnable{
privateCinemacinema;
publicTicketOffice2(Cinemacinema){
this.cinema=cinema;
}
//模拟对电影院操作
@Override
publicvoidrun(){
cinema.sellTickets2(2);
cinema.sellTickets2(4);
cinema.sellTickets1(2);
cinema.sellTickets1(1);
cinema.returnTickets2(2);
cinema.sellTickets1(3);
cinema.sellTickets2(2);
cinema.sellTickets1(2);
}
}

用synchronized关键字保护代码块时,我们使用对象作为它的传入参数。JVM保证同一时间只有一个线程能够访问这个对象保护的代码保护块(注意:我们一直谈论的是对象,不是类)。

备注:这个例子使用了一个对象来控制对vacanciesCinema1属性的访问,所以同一时间只有一个线程能够修改这个属性; 使用了另一个对象来控制vacanciesCinema2属性的访问,所以同一时间只有一个线程能够修改这个属性。但是,这个例子允许同时运行两个线程:一个修改vacancesCinema1属性,另一个修改vacanciesCinema2属性。

相关文章

什么是设计模式一套被反复使用、多数人知晓的、经过分类编目...
单一职责原则定义(Single Responsibility Principle,SRP)...
动态代理和CGLib代理分不清吗,看看这篇文章,写的非常好,强...
适配器模式将一个类的接口转换成客户期望的另一个接口,使得...
策略模式定义了一系列算法族,并封装在类中,它们之间可以互...
设计模式讲的是如何编写可扩展、可维护、可读的高质量代码,...