当使用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属性。