我们现在已理解了同步,接着可换从另一个角度来考察java beans。无论什么时候创建了一个bean,就必须假定它要在一个多线程的环境中运行。这意味着:
(1) 只要可行,bean的所有公共方法都应同步。当然,这也带来了“同步”在运行期间的开销。若特别在意这个问题,在关键区域中不会造成问题的方法就可保留为“不同步”,但注意这通常都不是十分容易判断。有资格的方法倾向于规模很小(如下例的getcirclesize())以及/或者“微小”。也就是说,这个方法调用在如此少的代码片里执行,以至于在执行期间对象不能改变。如果将这种方法设为“不同步”,可能对程序的执行速度不会有明显的影响。可能也将一个bean的所有public方法都设为synchronized,并只有在保证特别必要、而且会造成一个差异的情况下,才将synchronized关键字删去。
(2) 如果将一个多造型事件送给一系列对那个事件感兴趣的“听众”,必须假在列表中移动的时候可以添加或者删除。
第一点很容易处理,但第二点需要考虑更多的东西。让我们以前一章提供的bangbean.java为例。在那个例子中,我们忽略了synchronized关键字(那时还没有引入呢),并将造型设为单造型,从而回避了多线程的问题。在下面这个修改过的版本中,我们使其能在多线程环境中工作,并为事件采用了多造型技术:
//: bangbean2.java
// you should write your beans this way so they
// can run in a multithreaded environment.
import java.awt.*;
import java.awt.event.*;
import java.util.*;
import java.io.*;
public class bangbean2 extends canvas
implements serializable {
private int xm, ym;
private int csize = 20; // circle size
private string text = "bang!";
private int fontsize = 48;
private color tcolor = color.red;
private vector actionlisteners = new vector();
public bangbean2() {
addmouselistener(new ml());
addmousemotionlistener(new mm());
}
public synchronized int getcirclesize() {
return csize;
}
public synchronized void
setcirclesize(int newsize) {
csize = newsize;
}
public synchronized string getbangtext() {
return text;
}
public synchronized void
setbangtext(string newtext) {
text = newtext;
}
public synchronized int getfontsize() {
return fontsize;
}
public synchronized void
setfontsize(int newsize) {
fontsize = newsize;
}
public synchronized color gettextcolor() {
return tcolor;
}
public synchronized void
settextcolor(color newcolor) {
tcolor = newcolor;
}
public void paint(graphics g) {
g.setcolor(color.black);
g.drawoval(xm - csize/2, ym - csize/2,
csize, csize);
}
// this is a multicast listener, which is
// more typically used than the unicast
// approach taken in bangbean.java:
public synchronized void addactionlistener (
actionlistener l) {
actionlisteners.addelement(l);
}
public synchronized void removeactionlistener(
actionlistener l) {
actionlisteners.removeelement(l);
}
// notice this isn't synchronized:
public void notifylisteners() {
actionevent a =
new actionevent(bangbean2.this,
actionevent.action_performed, null);
vector lv = null;
// make a copy of the vector in case someone
// adds a listener while we're
// calling listeners:
synchronized(this) {
lv = (vector)actionlisteners.clone();
}
// call all the listener methods:
for(int i = 0; i < lv.size(); i++) {
actionlistener al =
(actionlistener)lv.elementat(i);
al.actionperformed(a);
}
}
class ml extends mouseadapter {
public void mousepressed(mouseevent e) {
graphics g = getgraphics();
g.setcolor(tcolor);
g.setfont(
new font(
"timesroman", font.bold, fontsize));
int width =
g.getfontmetrics().stringwidth(text);
g.drawstring(text,
(getsize().width - width) /2,
getsize().height/2);
g.dispose();
notifylisteners();
}
}
class mm extends mousemotionadapter {
public void mousemoved(mouseevent e) {
xm = e.getx();
ym = e.gety();
repaint();
}
}
// testing the bangbean2:
public static void main(string[] args) {
bangbean2 bb = new bangbean2();
bb.addactionlistener(new actionlistener() {
public void actionperformed(actionevent e){
system.out.println("actionevent" + e);
}
});
bb.addactionlistener(new actionlistener() {
public void actionperformed(actionevent e){
system.out.println("bangbean2 action");
}
});
bb.addactionlistener(new actionlistener() {
public void actionperformed(actionevent e){
system.out.println("more action");
}
});
frame aframe = new frame("bangbean2 test");
aframe.addwindowlistener(new windowadapter(){
public void windowclosing(windowevent e) {
system.exit(0);
}
});
aframe.add(bb, borderlayout.center);
aframe.setsize(300,300);
aframe.setvisible(true);
}
}
很容易就可以为方法添加synchronized。但注意在addactionlistener()和removeactionlistener()中,现在添加了actionlistener,并从一个vector中移去,所以能够根据自己愿望使用任意多个。
我们注意到,notifylisteners()方法并未设为“同步”。可从多个线程中发出对这个方法的调用。另外,在对notifylisteners()调用的中途,也可能发出对addactionlistener()和removeactionlistener()的调用。这显然会造成问题,因为它否定了vector actionlisteners。为缓解这个问题,我们在一个synchronized从句中“克隆”了vector,并对克隆进行了否定。这样便可在不影响notifylisteners()的前提下,对vector进行操纵。
paint()方法也没有设为“同步”。与单纯地添加自己的方法相比,决定是否对过载的方法进行同步要困难得多。在这个例子中,无论paint()是否“同步”,它似乎都能正常地工作。但必须考虑的问题包括:
(1) 方法会在对象内部修改“关键”变量的状态吗?为判断一个变量是否“关键”,必须知道它是否会被程序中的其他线程读取或设置(就目前的情况看,读取或设置几乎肯定是通过“同步”方法进行的,所以可以只对它们进行检查)。对paint()的情况来说,不会发生任何修改。
(2) 方法要以这些“关键”变量的状态为基础吗?如果一个“同步”方法修改了一个变量,而我们的方法要用到这个变量,那么一般都愿意把自己的方法也设为“同步”。基于这一前提,大家可观察到csize由“同步”方法进行了修改,所以paint()应当是“同步”的。但在这里,我们可以问:“假如csize在paint()执行期间发生了变化,会发生的最糟糕的事情是什么呢?”如果发现情况不算太坏,而且仅仅是暂时的效果,那么最好保持paint()的“不同步”状态,以避免同步方法调用带来的额外开销。
(3) 要留意的第三条线索是paint()基础类版本是否“同步”,在这里它不是同步的。这并不是一个非常严格的参数,仅仅是一条“线索”。比如在目前的情况下,通过同步方法(好csize)改变的一个字段已合成到paint()公式里,而且可能已改变了情况。但请注意,synchronized不能继承――也就是说,假如一个方法在基础类中是“同步”的,那么在衍生类过载版本中,它不会自动进入“同步”状态。
testbangbean2中的测试代码已在前一章的基础上进行了修改,已在其中加入了额外的“听众”,从而演示了bangbean2的多造型能力。
闽公网安备 35060202000074号