編號(hào)： 時(shí)間：2021年x月x日 書(shū)山有路勤為徑，學(xué)海無(wú)涯苦作舟 頁(yè)碼：第9頁(yè) 共9頁(yè) 第9章 多線(xiàn)程與Applet //例程9-1：Pi.java /*演示采用多線(xiàn)程技術(shù)計(jì)算圓周率*/ public class Pi{ public static void main(String[] args){ PiCaculator pc = new PiCaculator(); Thread t = new Thread(pc); t.start(); try{ Thread.sleep (10000); //休眠，等待可能出現(xiàn)的異常情況 t.interrupt (); }catch(InterruptedException e){ e.printStackTrace(); } } } class PiCaculator implements Runnable{ private double latestPiEstimate; public void run(){ try{ System.out.print ("Math.PI = "+ Math.PI + "\t" ); calPi(0.00001); System.out.println ("the latest PI = "+this.latestPiEstimate ); }catch(InterruptedException e){ System.out.println("The caculator is Interrupted."); } } /**用于計(jì)算圓周率的方法，accuracy為計(jì)算精度*/ private void calPi(double accuracy) throws InterruptedException { this.latestPiEstimate =0.0; long iteration = 0; int sign = -1; //按給定精度計(jì)算圓周率 while(Math.abs (Math.PI-this.latestPiEstimate)>accuracy){ if(Thread.interrupted ()) throw new InterruptedException(); iteration++; sign = -sign; this.latestPiEstimate += (sign*4.0/(2*iteration-1)); } } } //例程9-2：SynDemo.java /*演示沒(méi)有進(jìn)行線(xiàn)程同步所帶來(lái)的問(wèn)題*/ public class SynDemo{ public static void main(String[] args){ Demostrator shareDemostrator = new Demostrator(); Thread t1 = new Thread(shareDemostrator,"t1"); Thread t2 = new Thread(shareDemostrator,"t2"); t1.start(); t2.start(); } } class Demostrator implements Runnable{ private int shareData = 0; public void run(){ Thread t = Thread.currentThread (); for(int i = 1; i <= 5; i++){ int copy = shareData; try{ Thread.sleep ((int)(Math.random ()*1000)); }catch(Exception e){ e.printStackTrace(); } System.out.println ("Thread "+t.getName ()+": copy="+copy +"\tshareData="+shareData); shareData++; } } } //例程9-3：DeadLockDemo.java public class DeadLockDemo{ public static void main(String[] args){ DemoObject a = new DemoObject(); DemoObject b = new DemoObject(); a.another = b; b.another = a; Thread t1 = new Thread(a,"t1"); Thread t2 = new Thread(b,"t2"); t1.start (); t2.start (); } } class DemoObject implements Runnable{ public DemoObject another = null; public void run(){ this.method (); } public synchronized void method(){ if(this.another != null){ try{ Thread.sleep (1000); }catch(Exception e){ e.printStackTrace(); } another.method (); //下面的代碼段實(shí)際上是執(zhí)行不到的 System.out.println ("If you can see this line,no deadlock happened"); } } } //例程9-4: ThreeThreadDemo.java /*ThreeThreadDemo.java*/ public class ThreeThreadDemo{ public static void main(String[] args){ //創(chuàng)建新線(xiàn)程 CustomThread ct1 = new CustomThread(0); CustomThread ct2 = new CustomThread(1); //啟動(dòng)新線(xiàn)程 ct1.start (); ct2.start (); //輸出main線(xiàn)程信息 for(int i = 0; i < 5; i++){ System.out.println("main thread: "+i); } System.out.println ("main thread has done!"); } } class CustomThread extends Thread{ int id; public CustomThread(int customThreadID){ this.id = customThreadID; } //重定義子線(xiàn)程的run()方法 public void run(){ //輸出自定義線(xiàn)程的信息 for(int i = 0; i < 5; i++){ System.out.println ("CustomThread #"+ this.id +": "+i); } System.out.println ("CustomThread #"+this.id+" has done!"); } } //例程9-5：DigitalClock.java /*采用多線(xiàn)程技術(shù)演示一個(gè)簡(jiǎn)單的數(shù)字時(shí)鐘*/ import java.awt.event.*; import java.awt.*; import javax.swing.*; public class DigitalClock extends JFrame{ public static void main(String[] args) { JFrame frame = new DigitalClock(); frame.show(); } public DigitalClock(){ this.setSize(200,150); this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); //數(shù)字時(shí)鐘面板 final ClockPane cp = new ClockPane(); //設(shè)置按鈕狀態(tài)并注冊(cè)事件監(jiān)聽(tīng)者 final JButton start = new JButton("start"); final JButton stop = new JButton("stop"); stop.setEnabled(false); start.addActionListener(new ActionListener(){ public void actionPerformed(ActionEvent e){ cp.startClock(); start.setEnabled(false); stop.setEnabled(true); } }); stop.addActionListener(new ActionListener(){ public void actionPerformed(ActionEvent e){ cp.stopClock (); start.setEnabled(true); stop.setEnabled(false); } }); //設(shè)置面板布局 JPanel buttomPane = new JPanel(); buttomPane.add(start); buttomPane.add(stop); JPanel contentPane = new JPanel(); contentPane.setLayout(new BorderLayout()); contentPane.add(cp,BorderLayout.CENTER); contentPane.add(buttomPane,BorderLayout.SOUTH); this.setContentPane(contentPane); this.setResizable(false); } } //例程9-6：ClockPane.java /*數(shù)字時(shí)鐘面板的實(shí)現(xiàn)類(lèi)*/ import javax.swing.JPanel; import java.util.*; import java.awt.*; import java.awt.font.FontRenderContext; import java.awt.geom.*; import java.text.*; public class ClockPane extends JPanel implements Runnable { //線(xiàn)程是否中止的標(biāo)志 boolean running = false; //用于顯示當(dāng)前時(shí)間的字符串 String time = "Clock"; Font font = new Font("SanSerif", Font.BOLD, 40); //啟動(dòng)報(bào)時(shí)器 public void startClock() { this.running = true; Thread t = new Thread(this); t.start(); } //終止報(bào)時(shí)器 public void stopClock() { this.running = false; } //實(shí)現(xiàn)Runnable接口的run（）方法 public void run() { while (this.running) { //獲取當(dāng)前時(shí)間并轉(zhuǎn)換成字符串 this.time = DateFormat.getTimeInstance().format(new Date()); this.repaint(); //讓當(dāng)前線(xiàn)程休眠1秒鐘 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } //輸出當(dāng)前時(shí)間 public void paintComponent(Graphics g) { super.paintComponent(g); Graphics2D g2 = (Graphics2D) g; g2.setFont(this.font); FontRenderContext contex = g2.getFontRenderContext(); Rectangle2D bound = this.font.getStringBounds(this.time, contex); int strX = (int) ((this.getWidth() - bound.getWidth()) / 2); int strY = (int) ((this.getHeight() - bound.getHeight()) / 2) + 40; g2.drawString(this.time, strX, strY); } } //例程9-7：IOPipeDemo.java /*演示采用管道機(jī)制的線(xiàn)程間通信*/ import java.io.*; public class IOPipeDemo{ public static void main(String[] args){ try{ //創(chuàng)建并連接管道 final PipedOutputStream pout = new PipedOutputStream(); final PipedInputStream pin = new PipedInputStream(pout); //創(chuàng)建并啟動(dòng)輸出線(xiàn)程 Thread outputThread = new Thread(new Runnable(){ public void run(){ writeBytes(pout); } }); outputThread.start(); //創(chuàng)建并啟動(dòng)輸入線(xiàn)程 Thread inputThread = new Thread(new Runnable(){ public void run(){ readBytes(pin); } }); inputThread.start(); }catch(IOException e){ e.printStackTrace(); } } //往管道中寫(xiě)入數(shù)據(jù) public static void writeBytes(OutputStream outstream){ try{ DataOutputStream out = new DataOutputStream( new BufferedOutputStream(outstream) ); Thread t = Thread.currentThread (); for(int i=0; i<10; i++){ System.out.println ("write integer "+i+" to pipe."); out.writeInt(i); t.yield (); } out.flush(); out.close(); System.out.println ("Write data to pipe has done"); }catch(IOException e){ e.printStackTrace(); } } //從管道中讀取數(shù)據(jù) public static void readBytes(InputStream inputstream){ try{ DataInputStream in = new DataInputStream( new BufferedInputStream(inputstream) ); Thread t = Thread.currentThread (); boolean eof = false; while(!eof){ try{ int i = in.readInt(); System.out.println("Read integer "+i+" from pipe"); t.yield (); }catch(EOFException e){ eof = true; } } System.out.println ("Read data from pipe has done"); }catch(IOException e){ e.printStackTrace(); } } } //例程9-8 Hello_World.java import javax.swing.*; import java.awt.*; public class Hello_world extends JApplet{ public void paint(Graphics g){ g.drawString("Hello,world!"，5，10); } } HelloWorld.html 代碼 <HTML> <HEAD><TITLE>HELLO,WORLD!</TITLE></HEAD> <BODY> <APPLET code="Hello_World.class" width=300 height=300></APPLET> </BODY> </HTML> 第 9 頁(yè) 共 9 頁(yè)