线程间通信

public class Test {
　　 private Handler sendHandler;
    public Test(){
        // 开启接收线程
        new Thread(new SendRunnable()).start();
    }
/**
     * 将消息放入队列
     * @param message
     */
    public synchronized void sendMessage(String message){
        if (sendHandler==null){
            return;
        }
        Looper looper = Looper.myLooper();
        Message msg = sendHandler.obtainMessage();
        msg.obj = message;
        sendHandler.sendMessage(msg);
    }

    /**
     * 独立线程，用于接收队列中要发送的消息。并且排队处理
     */
      class SendRunnable implements Runnable {
        @Override
        public void run() {
            String msg;
            Looper.prepare();
            sendHandler = new Handler(new Handler.Callback() {
                @Override
                public boolean handleMessage(@NonNull Message msg) {
                    {
                        System.out.println("收到消息："+ msg.obj);
                        System.out.println("模拟处理消息过程..." );
                        try {
                            Thread.sleep(300);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        System.out.println("完成消息处理" );
                        return false;
                    }
                }
            });
            Looper.loop();
        }
    }
}

　　Test test = new Test();
   /**
     * 模拟多线程并发，发送消息
     */
    public void beginTest(){
        new Thread(new Runnable() {
            @Override
            public void run() {
                final AtomicInteger atomicInteger = new AtomicInteger();
                for (int i =0 ;i <20; i ++){

                    new Thread(new Runnable() {
                        @Override
                        public void run() {
                            test.sendMessage("ving:" + atomicInteger.getAndIncrement());
                        }
                    }).start();
                }
            }
        }).start();
    }