Как создать поток Looper, а затем отправить ему сообщение немедленно?

Question

У меня есть рабочий поток, который сидит в фоновом режиме, обрабатывая сообщения. Что-то вроде этого:

class Worker extends Thread { 

    public volatile Handler handler; // actually private, of course 

    public void run() { 
     Looper.prepare(); 
     mHandler = new Handler() { // the Handler hooks up to the current Thread 
      public boolean handleMessage(Message msg) { 
       // ... 
      } 
     }; 
     Looper.loop(); 
    } 
} 

Из основного потока (поток пользовательского интерфейса, не так уж важно), я хотел бы сделать что-то вроде этого:

Worker worker = new Worker(); 
worker.start(); 
worker.handler.sendMessage(...); 

Беда в том, что это ставит меня для прекрасное состояние гонки: во время чтения worker.handler, нет никакого способа убедиться, что рабочий поток уже назначен этому полю!

Я не могу просто создать Handler из конструктора Worker «s, так как конструктор работает в основном потоке, поэтому Handler будет ассоциировать себя с неправильным потоком.

Это вряд ли кажется необычным сценарием. Я могу придумать несколько обходных путей, все они некрасиво:

1. Что-то вроде этого:

   class Worker extends Thread { 
   
       public volatile Handler handler; // actually private, of course 
   
       public void run() { 
        Looper.prepare(); 
        mHandler = new Handler() { // the Handler hooks up to the current Thread 
         public boolean handleMessage(Message msg) { 
          // ... 
         } 
        }; 
        notifyAll(); // <- ADDED 
        Looper.loop(); 
       } 
   } 
   

   И от основного потока:

   Worker worker = new Worker(); 
   worker.start(); 
   worker.wait(); // <- ADDED 
   worker.handler.sendMessage(...); 
   

   Но это не является надежным либо : если notifyAll() происходит до wait(), тогда мы никогда не проснемся!

2. Пройдя первоначальный Message на конструктор Worker, имея способ run(), разместите его. Специальное решение не будет работать для нескольких сообщений, или если мы не хотим сразу его отправлять, но вскоре.

3. Занято-ожидание до handler Поле больше не null. Да, в крайнем случае ...

Я хотел бы создать Handler и MessageQueue от имени Worker нити, но это не представляется возможным. Каков самый изящный выход из этого?

Answer 1

Eventual решение (минус проверка ошибок), благодаря CommonsWare:

class Worker extends HandlerThread { 

    // ... 

    public synchronized void waitUntilReady() { 
     d_handler = new Handler(getLooper(), d_messageHandler); 
    } 

} 

И от основного потока:

Worker worker = new Worker(); 
worker.start(); 
worker.waitUntilReady(); // <- ADDED 
worker.handler.sendMessage(...); 

Это работает благодаря семантике HandlerThread.getLooper(), который блокирует до тех пор, петлитель не имеет были инициализированы.

---

Кстати, это похоже на мое решение # 1 выше, поскольку HandlerThread реализуется примерно следующим образом (надо любить с открытым исходным кодом):

public void run() { 
    Looper.prepare(); 
    synchronized (this) { 
     mLooper = Looper.myLooper(); 
     notifyAll(); 
    } 
    Looper.loop(); 
} 

public Looper getLooper() { 
    synchronized (this) { 
     while (mLooper == null) { 
      try { 
       wait(); 
      } catch (InterruptedException e) { 
      } 
     } 
    } 
    return mLooper; 
} 

Основное различие заключается в том, что она не проверьте, работает ли рабочий поток, но он фактически создал петлитель; и способ сделать это - сохранить петлитель в частном поле. Ницца!

Answer 2

class WorkerThread extends Thread { 
      private Exchanger<Void> mStartExchanger = new Exchanger<Void>(); 
      private Handler mHandler; 
      public Handler getHandler() { 
        return mHandler; 
      } 
      @Override 
      public void run() { 
        Looper.prepare(); 
        mHandler = new Handler(); 
        try { 
          mStartExchanger.exchange(null); 
        } catch (InterruptedException e) { 
          e.printStackTrace(); 
        } 
        Looper.loop(); 
      } 

      @Override 
      public synchronized void start() { 
        super.start(); 
        try { 
          mStartExchanger.exchange(null); 
        } catch (InterruptedException e) { 
          e.printStackTrace(); 
        } 
      } 
    } 

Answer 3

посмотрите на исходный код HandlerThread

@Override 
    public void run() { 
     mTid = Process.myTid(); 
     Looper.prepare(); 
     synchronized (this) { 
      mLooper = Looper.myLooper(); 
      notifyAll(); 
     } 
     Process.setThreadPriority(mPriority); 
     onLooperPrepared(); 
     Looper.loop(); 
     mTid = -1; 
    } 

В принципе, если вы расширяете тему на работника и реализации собственного Looper, то ваш основной класс поток должен расширить рабочий и установить обработчик там.

Answer 4

Это мои решения: MainActivity:

//Other Code 

mCountDownLatch = new CountDownLatch(1); 
     mainApp = this; 
     WorkerThread workerThread = new WorkerThread(mCountDownLatch); 
     workerThread.start(); 
     try { 
      mCountDownLatch.await(); 
      Log.i("MsgToWorkerThread", "Worker Thread is up and running. We can send message to it now..."); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
     Toast.makeText(this, "Trial run...", Toast.LENGTH_LONG).show(); 
     Message msg = workerThread.workerThreadHandler.obtainMessage(); 
     workerThread.workerThreadHandler.sendMessage(msg); 

WorkerThread Класс:

public class WorkerThread extends Thread{ 

    public Handler workerThreadHandler; 
    CountDownLatch mLatch; 

    public WorkerThread(CountDownLatch latch){ 

     mLatch = latch; 
    } 


    public void run() { 
     Looper.prepare(); 
     workerThreadHandler = new Handler() { 
      @Override 
      public void handleMessage(Message msg) { 

       Log.i("MsgToWorkerThread", "Message received from UI thread..."); 
         MainActivity.getMainApp().runOnUiThread(new Runnable() { 

          @Override 
          public void run() { 
           Toast.makeText(MainActivity.getMainApp().getApplicationContext(), "Message received in worker thread from UI thread", Toast.LENGTH_LONG).show(); 
           //Log.i("MsgToWorkerThread", "Message received from UI thread..."); 
          } 
         }); 

      } 

     }; 
     Log.i("MsgToWorkerThread", "Worker thread ready..."); 
     mLatch.countDown(); 
     Looper.loop(); 
    } 
}