github項目代碼地址，歡迎start https://github.com/979451341/EventLine 接著上一篇繼續寫，這次我們要在接收函數上使用元註解來區別接收函數需要在哪個線程執行 然後在EventLine裡面添加兩個常量 使用元註解 實現我們需要得到activity的rece ...
github項目代碼地址，歡迎start
https://github.com/979451341/EventLine
接著上一篇繼續寫，這次我們要在接收函數上使用元註解來區別接收函數需要在哪個線程執行
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Process {
int value() default 0;
}
然後在EventLine裡面添加兩個常量
public final static int MainThread = 0;
public final static int SubThread = 1;
使用元註解
@Process(EventLine.SubThread)
public void receive(DataBean dataBean) throws InterruptedException {
Log.v("zzw","TwoActivity 接收到了"+dataBean.data);
Thread.sleep(3000);
Log.v("zzw","TwoActivity 接收結束");
}
實現
我們需要得到activity的receive函數Process這個元註解的值來判斷在哪個線程執行
final Method declaredMethod = cls.getDeclaredMethod("receive", ojb.getClass());
Annotation[] annotations = declaredMethod.getAnnotations();
for(Annotation annotation : annotations){
if(annotation.annotationType() == Process.class){
Process process = (Process)annotation;
value = process.value();
}
}
得到元註解的值後根據情況來執行
if(value == MainThread)
declaredMethod.invoke(activity, (Object) ojb);
else if(value == SubThread){
new Thread(new Runnable() {
@Override
public void run() {
try {
declaredMethod.invoke(activity, (Object) ojb);
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (InvocationTargetException e) {
e.printStackTrace();
}
}
}).start();
}
在主線程發送信息
DataBean dataBean = new DataBean();
dataBean.data = "來自ThreeActivity的消息";
EventLine.getInstance().postData(dataBean);
效果良好
01-25 16:57:27.562 31938-32011/com.example.zth.eventline V/zzw: MainActivity 接收到了來自ThreeActivity的消息 01-25 16:57:27.574 31938-32024/com.example.zth.eventline V/zzw: TwoActivity 接收到了來自ThreeActivity的消息 01-25 16:57:30.575 31938-32024/com.example.zth.eventline V/zzw: TwoActivity 接收結束
現在我們把發送信息的環節放在子線程
new Thread(new Runnable() {
@Override
public void run() {
DataBean dataBean = new DataBean();
dataBean.data = "來自ThreeActivity的消息";
EventLine.getInstance().postData(dataBean);
}
}).start();
效果依舊良好
01-25 16:57:27.562 31938-32011/com.example.zth.eventline V/zzw: MainActivity 接收到了來自ThreeActivity的消息 01-25 16:57:27.574 31938-32024/com.example.zth.eventline V/zzw: TwoActivity 接收到了來自ThreeActivity的消息 01-25 16:57:30.575 31938-32024/com.example.zth.eventline V/zzw: TwoActivity 接收結束
但是還是對EventLine做出一些改動，在元註解說要在主線程執行接收函數，
if(value == MainThread){
activity.runOnUiThread(new Runnable() {
@Override
public void run() {
try {
declaredMethod.invoke(activity, (Object) ojb);
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (InvocationTargetException e) {
e.printStackTrace();
}
}
});
}
else if(value == SubThread){
new Thread(new Runnable() {
@Override
public void run() {
try {
declaredMethod.invoke(activity, (Object) ojb);
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (InvocationTargetException e) {
e.printStackTrace();
}
}
}).start();
}
貼出EventLine完整代碼
public class EventLine<T> {
public static EventLine eventLine;
public final static int MainThread = 0;
public final static int SubThread = 1;
private EventLine(){
}
public static EventLine getInstance(){
if(eventLine == null){
synchronized (EventLine.class){
if(eventLine == null)
eventLine = new EventLine();
}
}
return eventLine;
}
private ArrayList<Activity> activities = new ArrayList<Activity>();
public void addActivity(Activity activity){
activities.add(activity);
}
public void removeActivity(Activity activity){
activities.remove(activity);
}
public void finishAll(){
for(Activity activity : activities){
activity.finish();
}
}
public void postData(final T ojb){
for(final Activity activity : activities){
int value = 0;
Class<? extends Activity> cls = activity.getClass();
try {
final Method declaredMethod = cls.getDeclaredMethod("receive", ojb.getClass());
Annotation[] annotations = declaredMethod.getAnnotations();
for(Annotation annotation : annotations){
if(annotation.annotationType() == Process.class){
Process process = (Process)annotation;
value = process.value();
}
}
if(value == MainThread){
activity.runOnUiThread(new Runnable() {
@Override
public void run() {
try {
declaredMethod.invoke(activity, (Object) ojb);
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (InvocationTargetException e) {
e.printStackTrace();
}
}
});
}
else if(value == SubThread){
new Thread(new Runnable() {
@Override
public void run() {
try {
declaredMethod.invoke(activity, (Object) ojb);
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (InvocationTargetException e) {
e.printStackTrace();
}
}
}).start();
}
} catch (NoSuchMethodException e) {
e.printStackTrace();
}
}
}
}
結束了，下一次寫一下Fragment與Fragment、activity之間的消息傳遞
