安卓怎么用rxjava实现线程间的传递数据

importjava.util.scanner;publicclasstest { publicstaticvoidmain(string[]args) { finalmessagemessage=newmessage();finalthreadthread=newthread(newrunnable(){ publicvoidrun(){ scannerscanner=newscanner(system.in); while(true){ stringmsg=scanner.next(); if(msg.equals("exit")) return; message.sendmessage(msg); } } }); thread.start();while(true){ if(thread.isalive()==false) break; stringmsg=message.receivemessage(); if(msg!=null){ system.out.println(msg); } try{ thread.sleep(100); }catch(interruptedexceptione){} }} }classmessage{ privatestringmessage; privatebooleanunread=false; synchronizedvoidsendmessage(stringmessage){ this.message=message; unread=true; }synchronizedstringreceivemessage(){ stringmsg=unread?message:null; unread=false; returnmsg; } }