/*
 * SyncDemo.java
 *
 * Created on 2005年4月11日, 下午12:33
 */

import javax.microedition.midlet.*;
import javax.microedition.lcdui.*;

/**
 *
 * @author  Liu Bin
 * @version
 */
public class SyncDemo extends MIDlet implements CommandListener {
    //Display管理
    Display display = null;
    Form form = new Form("線程同步演示");
    
    Command cmdExit = new Command("退出", Command.STOP, 1);
    Command cmdRun = new Command("運行", Command.ITEM, 2);
    Command cmdStop = new Command("停止", Command.ITEM, 2);
    
    //共享變量
    int sharedCounter = 0;
    
    MyThreaad p1, p2, p3;
    
    public SyncDemo() {
        form.addCommand(cmdExit);
        form.addCommand(cmdRun);
        form.setCommandListener(this);
    }
    public void startApp() {
        
        display = Display.getDisplay(this); //獲得當前MIDlet的Display對象
        display.setCurrent(form);           //設置form對象為當前顯示對象
    }
    
    public void pauseApp() {
    }
    
    public void destroyApp(boolean unconditional) {
        notifyDestroyed();
    }
    
    /**
     * 處理命令按鈕事件
     */
    public void commandAction(Command cmd, Displayable d) {
        if (cmd == cmdExit) {
            destroyApp(true);
        } else if (cmd == cmdRun) {
            //創建線程1
            p1 = new MyThreaad(this, 1);
            //執行線程1
            p1.start();
            
            //創建線程2
            p2 = new MyThreaad(this, 2);
            //執行線程2
            p2.start();
            
            //創建線程3
            p3 = new MyThreaad(this, 3);
            //執行線程3
            p3.start();
            
            form.removeCommand(cmdRun);
            form.addCommand(cmdStop);
        } else if (cmd == cmdStop) {
            form.removeCommand(cmdStop);
            form.addCommand(cmdRun);
            
            p1.stopFlag = true;
            p2.stopFlag = true;
            p3.stopFlag = true;
        }
    }
    
    
    /**
     * 從Thread繼承創建線程
     */
    class MyThreaad extends Thread {
        //當前線程的ID標識
        long id;
        SyncDemo instance;
        public boolean stopFlag;
        
        MyThreaad(SyncDemo father, long id) {
            instance = father;
            this.id = id;
        }
        
        public void run() {
            stopFlag = false;
            System.out.println("線程"+ id + "開始執行\n");
            while (!stopFlag) {
                synchronized(instance) {
                    System.out.println("線程"+id + "，優先級" +
                            this.getPriority() + "   當前值: " +
                            instance.sharedCounter++);
                    System.out.println("線程"+id + "，優先級" +
                            this.getPriority() + "   新值: " +
                            instance.sharedCounter);
                }
            }
            System.out.println("線程"+ id + "執行完畢\n");
        }
    }
}