Handler之消息循環 Handler是用於操做線程內部的消息隊列的類。這有點繞,不要緊,咱們慢慢的來說。前面Looper一篇講到了Looper是用於給線程建立消息隊列用的,也就是說Looper可讓消息隊列(MessageQueue)附屬在線程以內,並讓消息隊列循環起來,接收並處理消息。但,咱們並不直接的操做消息隊列,而是用Handler來操做消息隊列,給消息隊列發送消息,和從消息隊列中取出消息並處理。這就是Handler的職責。 Handler,Looper和MessageQueue是屬於一個線程內部的數據,可是它提供給外部線程訪問的接口,Handler就是公開給外部線程,與線程通信的接口。換句話說,這三個東西都是用來線程間通信用的(ITC--Inter Thread Communication),與進行間通信(IPC--Inter Process Communication)的消息隊列msgque的核心思想是一致的。MessageQueue是相對較底層的,較少直接使用,Looper和Handler就是專門用來操做底層MessageQueue的。 還有一個重要的數據結構是通信的基本元素,就是消息對象(Message),Message歷來不單獨使用,它都是跟隨Handler來使用的。具體方法能夠參考文檔,但須要注意的是同一個消息對象不能發送二次,不然會有AndroidRuntimeException: { what=1000 when=-15ms obj=.. } This message is already in use."。每次發送消息前都要經過Message.obtain()來獲取新的對象,或者,對於不須要傳送額外數據的直接發送空消息就好Handler.sendEmptyMessage(int)。另外也須要注意消息對象是不能手動回收的,也就是說你不能調用Message.recycle()來釋放一個消息對象,由於當該對象被從隊列中取出處理完畢後,MessageQueue內部會自動的去作recycle()。這個理解起來也很容易,由於發送一個消息到消息隊列後,消息何時會被處理,對於應用程序來說是不知道的,只有MessageQueue纔會知道,因此只能由MessageQueue來作回收釋放的動做。 由於Handler是用於操做一個線程內部的消息隊列的,因此Handler必須依附於一個線程,並且只能是一個線程。換句話說,你必須在一個線程內建立Handler,同時指定Handler的回調handlerMessage(Message msg)。 Handler主要有二個用途,一個是用於線程內部消息循環; 另一個就是用於線程間通信。 Handler的基本用法能夠參考文檔,說的仍是比較清楚的。 用於線程內部消息循環 主要是用做在未來定時作某個動做,或者循環性,週期性的作某個動做。主要的接口就是 Handler.sendEmptyMessageDelayed(int msgid, long after); Handler.sendMessageDelayed(Message msg, long after); Handler.postDelayed(Runnable task, long after); Handler.sendMessageAtTime(Message msg, long timeMillis); Handler.sendEmptyMessageAtTime(int id, long timeMiilis); Handler.postAtTime(Runnable task, long timeMillis); 這些方法的目的都是設置一個定時器,在指定的時間後,或者在指定的時間向Handler所在的MessageQueue發送消息。這樣就很是方便應用程序實現定時操做,或者循環時序操做(處理消息時再延時發送消息,以達成循環時序)。 這個使用起來並不難,但須要注意一點的是,線程內部消息循環並非併發處理,也就是全部的消息都是在Handler所屬的線程內處理的,因此雖然你用post(Runnable r),發給MessageQueue一個Runnable,但這並不會建立新的線程來執行,處理此消息時僅是調用r.run()。(想要另起線程執行,必須把Runnable放到一個Thread中)。 實例 這裏用一個實例來展現主線程經過Handler與後臺線程進行通訊,而且主線程用Handler來實現循環時序。 播放一個視頻,線程用於建立和初始化MediaPlayer,初始化好後會經過主線程的Handler告訴主線程,而後主線程能夠播放視頻,在播放過程當中經過sendMessageDelayed()來實現播放進度的不斷更新: [java] public class HandlerSimpleDemo extends Activity { protected static final String TAG = "HandlerSimpleDemo"; private static final int MEDIA_PLAYER_READY = 0; private static final int REFRESH_PROGRESS = 1; private Button mStart; private Button mStop; private SurfaceHolder mSurfaceHolder; private ProgressBar mProgressBar; private SurfaceView mDisplay; private MediaPlayer mMediaPlayer; private Handler mMainHandler = new Handler() { @Override public void handleMessage(Message msg) { switch (msg.what) { case MEDIA_PLAYER_READY: mProgressBar.setMax(mMediaPlayer.getDuration()); mMediaPlayer.setOnCompletionListener(new MediaPlayer.OnCompletionListener() { public void onCompletion(MediaPlayer mp) { mProgressBar.setProgress(mMediaPlayer.getDuration()); mMainHandler.removeMessages(REFRESH_PROGRESS); } }); mStart.setEnabled(true); mStop.setEnabled(true); break; case REFRESH_PROGRESS: int cp = mMediaPlayer.getCurrentPosition(); mProgressBar.setProgress(cp); int delay = 1000 - (cp % 1000); mMainHandler.sendEmptyMessageDelayed(REFRESH_PROGRESS, delay); break; default: break; } } }; @SuppressWarnings("deprecation") @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.handler_simple_demo); mStart = (Button) findViewById(R.id.handler_simple_start); mStart.setOnClickListener(new View.OnClickListener() { public void onClick(View v) { mMediaPlayer.start(); mMainHandler.sendEmptyMessage(REFRESH_PROGRESS); } }); mStart.setEnabled(false); mStop = (Button) findViewById(R.id.handler_simple_stop); mStop.setOnClickListener(new View.OnClickListener() { public void onClick(View v) { mMainHandler.removeMessages(REFRESH_PROGRESS); mMediaPlayer.pause(); } }); mStop.setEnabled(false); mProgressBar = (ProgressBar) findViewById(R.id.handler_simple_progress); mDisplay = (SurfaceView) findViewById(R.id.handler_simple_display); mSurfaceHolder = mDisplay.getHolder(); mSurfaceHolder.setFixedSize(mDisplay.getWidth(), mDisplay.getHeight()); // Do not believe the document, setType is necessary, otherwise, video won't play correctly mSurfaceHolder.setType(SurfaceHolder.SURFACE_TYPE_PUSH_BUFFERS); new Thread(new Runnable() { public void run() { try { mMediaPlayer = MediaPlayer.create(getApplication(), R.raw.flug); mMediaPlayer.setDisplay(mSurfaceHolder); mMainHandler.sendEmptyMessage(MEDIA_PLAYER_READY); } catch (IllegalArgumentException e) { Log.e(TAG, "caught exception e", e); } catch (SecurityException e) { Log.e(TAG, "caught exception e", e); } catch (IllegalStateException e) { Log.e(TAG, "caught exception e", e); } } }).start(); } @Override protected void onDestroy() { super.onDestroy(); mMainHandler.removeMessages(REFRESH_PROGRESS); if (mMediaPlayer != null) { mMediaPlayer.release(); } } }