按键盘上方向键 ← 或 → 可快速上下翻页,按键盘上的 Enter 键可回到本书目录页,按键盘上方向键 ↑ 可回到本页顶部!
————未阅读完?加入书签已便下次继续阅读!
Thread 是一个内部类。这使得程序的编写稍微方便一些,因为它取消了 Counter2。java 中一些额外的记录工
作。
//: Suspend。java
// The alternative approach to using suspend()
// and resume(); which have been deprecated
// in Java 1。2。
import java。awt。*;
import java。awt。event。*;
import java。applet。*;
public class Suspend extends Applet {
private TextField t = new TextField(10);
private Button
suspend = new Button(〃Suspend〃);
resume = new Button(〃Resume〃);
class Suspendable extends Thread {
private int count = 0;
private boolean suspended = false;
public Suspendable() { start(); }
public void fauxSuspend() {
suspended = true;
}
public synchronized void fauxResume() {
suspended = false;
notify();
}
public void run() {
while (true) {
try {
sleep(100);
synchronized(this) {
while(suspended)
wait();
}
} catch (InterruptedException e){}
t。setText(Integer。toString(count++));
}
}
}
private Suspendable ss = new Suspendable();
public void init() {
add(t);
suspend。addActionListener(
new ActionListener() {
public
void actionPerformed(ActionEvent e) {
ss。fauxSuspend();
}
});
add(suspend);
520
…………………………………………………………Page 522……………………………………………………………
resume。addActionListener(
new ActionListener() {
public
void actionPerformed(ActionEvent e) {
ss。fauxResume();
}
});
add(resume);
}
public static void main(String'' args) {
Suspend applet = new Suspend();
Frame aFrame = new Frame(〃Suspend〃);
aFrame。addWindowListener(
new WindowAdapter() {
public void windowClosing(WindowEvent e){
System。exit(0);
}
});
aFrame。add(applet; BorderLayout。CENTER);
aFrame。setSize(300;100);
applet。init();
applet。start();
aFrame。setVisible(true);
}
} ///:~
Suspendable 中的suspended (已挂起)标志用于开关“挂起”或者“暂停”状态。为挂起一个线程,只需调
用fauxSuspend()将标志设为 true (真)即可。对标志状态的侦测是在run()内进行的。就象本章早些时候
提到的那样,wait()必须设为“同步”(synchronized),使其能够使用对象锁。在fauxResume()中,
suspended 标志被设为 false (假),并调用notify()——由于这会在一个“同步”从句中唤醒wait(),所
以fauxResume()方法也必须同步,使其能在调用notify()之前取得对象锁(这样一来,对象锁可由要唤醍的
那个wait()使用)。如果遵照本程序展示的样式,可以避免使用wait()和notify() 。
Thread 的 destroy()方法根本没有实现;它类似一个根本不能恢复的suspend(),所以会发生与suspend()一
样的死锁问题。然而,这一方法没有得到明确的“反对”,也许会在 Java 以后的版本(1。2版以后)实现,
用于一些可以承受死锁危险的特殊场合。
大家可能会奇怪当初为什么要实现这些现在又被“反对”的方法。之所以会出现这种情况,大概是由于 Sun
公司主要让技术人员来决定对语言的改动,而不是那些市场销售人员。通常,技术人员比搞销售的更能理解
语言的实质。当初犯下了错误以后,也能较为理智地正视它们。这意味着 Java 能够继续进步,即便这使
Java 程序员多少感到有些不便。就我自己来说,宁愿面对这些不便之处,也不愿看到语言停滞不前。
14。4 优先级
线程的优先级(Priority )告诉调试程序该线程的重要程度有多大。如果有大量线程都被堵塞,都在等候运
行,调试程序会首先运行具有最高优先级的那个线程。然而,这并不表示优先级较低的线程不会运行(换言
之,不会因为存在优先级而导致死锁)。若线程的优先级较低,只不过表示它被准许运行的机会小一些而
已。
可用getPriority()方法读取一个线程的优先级,并用 setPriority()改变它。在下面这个程序片中,大家会
发现计数器的计数速度慢了下来,因为它们关联的线程分配了较低的优先级:
//: Counter5。java
// Adjusting the priorities of threads
import java。awt。*;
import java。awt。event。*;
521
…………………………………………………………Page 523……………………………………………………………
import java。applet。*;
class Ticker2 extends Thread {
private Button
b = new Button(〃Toggle〃);
incPriority = new Button(〃up〃);
decPriority = new Button(〃down〃);
private TextField
t = new TextField(10);
pr = new TextField(3); // Display priority
private int count = 0;
private boolean runFlag = true;
public Ticker2(Container c) {
b。addActionListener(new ToggleL());
incPriority。addActionListener(new UpL());
decPriority。addActionListener(new DownL());
Panel p = new Panel();
p。add(t);
p。add(pr);
p。add(b);
p。add(incPriority);
p。add(decPriority);
c。add(p);
}
class ToggleL implements ActionListener {
public void actionPerformed(ActionEvent e) {
runFlag = !runFlag;
}
}
class UpL implements ActionListener {
public void actionPerformed(ActionEvent e) {
int newPriority = getPriority() + 1;
if(newPriority 》 Thread。MAX_PRIORITY)
newPriority = Thread。MAX_PRIORITY;
setPriority(newPriority);
}
}
class DownL implements ActionListener {
public void actionPerformed(ActionEvent e) {
int newPriority = getPriority() 1;
if(newPriority 《 Thread。MIN_PRIORITY)
newPriority = Thread。MIN_PRIORITY;
setPriority(newPriority);
}
}
public void run() {
while (true) {
if(runFlag) {
t。setText(Integer。toString(count++));
pr。setText(
Integer。toString(getPriority()));
}