用Java自己實(shí)現(xiàn)一個消息循環(huán)

ActivityThread類

public class ActivityThread {

    public static String currentThreadInfo() {
        Thread thread = Thread.currentThread();
        return "Thread id: " + thread.getId() + ", " + thread.toString();
    }

    public static void main(String[] args) {
        System.out.println(">>>onCreate");
        System.out.println("MainThread: " + currentThreadInfo());

        startTaskThread();

        Looper.prepareMainLooper();
        Looper.loop();
    }

    private static void startTaskThread() {
        new Thread(new Runnable() {
            @Override
            public void run() {
                while (true) {
                    try {
                        final long millis = (long) (2000 + Math.random() * 3000);
                        Thread.sleep(millis);
                        Handler handler = new Handler(Looper.getMainLooper(), new Handler.Callback() {
                            @Override
                            public boolean handleMessage(Message msg) {
                                return false;
                            }
                        }) {
                            @Override
                            public void handleMessage(Message msg) {
                                super.handleMessage(msg);
                            }
                        };
                        System.out.println();
                        System.out.println("Task " + millis + " Create In: " + currentThreadInfo());
                        handler.post(new Runnable() {
                            @Override
                            public void run() {
                                System.out.println("Task " + millis + " Run In: " + currentThreadInfo());
                            }
                        });
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }).start();
    }
}

Handler類

public class Handler {
    final Looper mLooper;
    final MessageQueue mQueue;
    final Callback mCallback;

    public Handler() {
        this(Looper.myLooper());
    }

    public Handler(Looper looper) {
        this(looper, looper.mQueue, null);
    }

    public Handler(Looper looper, Callback callback) {
        this(looper, looper.mQueue, callback);
    }

    public Handler(Looper looper, MessageQueue queue, Callback callback) {
        mLooper = looper;
        mQueue = queue;
        mCallback = callback;
    }

    public void dispatchMessage(Message msg) {
        if (msg.callback != null) {
            handleCallback(msg);
        } else {
            if (mCallback != null) {
                if (mCallback.handleMessage(msg)) {
                    return;
                }
            }
            handleMessage(msg);
        }
    }

    public final void sendMessage(Message msg) {
        msg.target = this;
        mQueue.enqueueMessage(msg);
    }

    public void handleMessage(Message msg) {
    }

    public interface Callback {
        boolean handleMessage(Message msg);
    }

    private static void handleCallback(Message message) {
        message.callback.run();
    }

    public final void post(Runnable runnable) {
        Message msg = new Message();
        msg.callback = runnable;
        sendMessage(msg);
    }
}

Looper類

public class Looper {
    private static final ThreadLocal<Looper> sThreadLocal = new ThreadLocal<>();
    private static Looper sMainLooper;

    final MessageQueue mQueue = new MessageQueue();

    public static Looper getMainLooper() {
        return sMainLooper;
    }

    public static void prepareMainLooper() {
        prepare();
        synchronized (Looper.class) {
            if (sMainLooper != null) {
                throw new IllegalStateException("The main Looper has already been prepared.");
            }
            sMainLooper = myLooper();
        }
    }

    public static Looper myLooper() {
        return sThreadLocal.get();
    }

    public static void prepare() {
        if (sThreadLocal.get() != null) {
            throw new RuntimeException("Only one Looper may be created per thread");
        }
        sThreadLocal.set(new Looper());
    }

    public static void loop() {
        Looper looper = myLooper();
        for (; ; ) {
            Message msg = looper.mQueue.next();
            if (msg != null) {
                msg.target.dispatchMessage(msg);
            }
        }
    }
}

Message類

public class Message {
    public int what;
    public int arg1;
    public int arg2;

    Handler target;
    Runnable callback;

    @Override
    public String toString() {
        return "Message{" +
                "what=" + what +
                ", arg1=" + arg1 +
                ", arg2=" + arg2 +
                ", target=" + target +
                ", callback=" + callback +
                '}';
    }
}

MessageQueue類

import java.util.LinkedList;
import java.util.Queue;

public class MessageQueue {
    private final Queue<Message> mMessages = new LinkedList<>();

    public void enqueueMessage(Message msg) {
        synchronized (mMessages) {
            mMessages.add(msg);
            mMessages.notifyAll();
        }
    }

    public Message next() {
        synchronized (mMessages) {
            if (!mMessages.isEmpty()) {
                return mMessages.poll();
            }
            try {
                mMessages.wait();
                if (!mMessages.isEmpty()) {
                    return mMessages.poll();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        return next();
    }
}

把上面幾個類復(fù)制到一個Java工程里说莫,運(yùn)行ActivityThread的main方法即可杨箭。整體API跟Android的一致。通過wait和notify來避免死循環(huán)的性能問題储狭,Android是通過MessageQueue.nativePollOnce Linux的epoll實(shí)現(xiàn)互婿。但消息循環(huán)部分完全一致。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末辽狈,一起剝皮案震驚了整個濱河市慈参,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌刮萌,老刑警劉巖驮配,帶你破解...
    沈念sama閱讀 222,729評論 6 517
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異着茸,居然都是意外死亡壮锻,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,226評論 3 399
  • 文/潘曉璐 我一進(jìn)店門涮阔,熙熙樓的掌柜王于貴愁眉苦臉地迎上來猜绣,“玉大人,你說我怎么就攤上這事澎语⊥臼拢” “怎么了?”我有些...
    開封第一講書人閱讀 169,461評論 0 362
  • 文/不壞的土叔 我叫張陵擅羞,是天一觀的道長尸变。 經(jīng)常有香客問我,道長减俏,這世上最難降的妖魔是什么召烂? 我笑而不...
    開封第一講書人閱讀 60,135評論 1 300
  • 正文 為了忘掉前任,我火速辦了婚禮娃承,結(jié)果婚禮上奏夫,老公的妹妹穿的比我還像新娘。我一直安慰自己历筝,他們只是感情好酗昼,可當(dāng)我...
    茶點(diǎn)故事閱讀 69,130評論 6 398
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著梳猪,像睡著了一般麻削。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 52,736評論 1 312
  • 那天呛哟,我揣著相機(jī)與錄音叠荠,去河邊找鬼。 笑死扫责,一個胖子當(dāng)著我的面吹牛榛鼎,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播鳖孤,決...
    沈念sama閱讀 41,179評論 3 422
  • 文/蒼蘭香墨 我猛地睜開眼者娱,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了淌铐?” 一聲冷哼從身側(cè)響起肺然,我...
    開封第一講書人閱讀 40,124評論 0 277
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎腿准,沒想到半個月后际起,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 46,657評論 1 320
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡吐葱,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,723評論 3 342
  • 正文 我和宋清朗相戀三年街望,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片弟跑。...
    茶點(diǎn)故事閱讀 40,872評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡灾前,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出孟辑,到底是詐尸還是另有隱情哎甲,我是刑警寧澤,帶...
    沈念sama閱讀 36,533評論 5 351
  • 正文 年R本政府宣布饲嗽,位于F島的核電站炭玫,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏貌虾。R本人自食惡果不足惜吞加,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,213評論 3 336
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望尽狠。 院中可真熱鬧衔憨,春花似錦、人聲如沸袄膏。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,700評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽沉馆。三九已至平项,卻和暖如春赫舒,著一層夾襖步出監(jiān)牢的瞬間悍及,已是汗流浹背闽瓢。 一陣腳步聲響...
    開封第一講書人閱讀 33,819評論 1 274
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留心赶,地道東北人扣讼。 一個月前我還...
    沈念sama閱讀 49,304評論 3 379
  • 正文 我出身青樓,卻偏偏與公主長得像缨叫,于是被迫代替她去往敵國和親椭符。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,876評論 2 361

推薦閱讀更多精彩內(nèi)容