synchronized register and unregister

mrsimple · mrsimple · commit 88b24b8b51e3 · 2015-02-05T10:31:26.000+08:00
diff --git a/Simple_eventbus_demo/src/org/simple/eventbus/demo/fragment/MenuFragment.java b/Simple_eventbus_demo/src/org/simple/eventbus/demo/fragment/MenuFragment.java
@@ -23,13 +23,16 @@
 import android.view.View.OnClickListener;
 import android.view.ViewGroup;
 import android.widget.TextView;
+import android.widget.Toast;
 
 import org.simple.eventbus.EventBus;
 import org.simple.eventbus.Subcriber;
 import org.simple.eventbus.ThreadMode;
 import org.simple.eventbus.demo.R;
 import org.simple.eventbus.demo.bean.User;
 
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Random;
 
 /**
@@ -77,6 +80,13 @@ public void onClick(View v) {
                         // 移除用户
                         EventBus.getDefault().post(new User("User - 1"),
                                 "remove");
+
+                        List<User> users = new ArrayList<User>();
+                        for (int i = 0; i < 5; i++) {
+                            users.add(new User("user - " + i));
+                        }
+
+                        EventBus.getDefault().post(users, "list");
                     }
                 });
 
@@ -109,6 +119,14 @@ private void updateClickUserName(User clickPerson) {
         mUserNameTv.setText(clickPerson.name);
     }
 
+    @Subcriber(tag = "list")
+    private void subcribeList(List<User> users) {
+        Toast.makeText(getActivity(), "list", Toast.LENGTH_SHORT).show();
+        for (int i = 0; i < threads.length; i++) {
+            Log.e(getTag(), "### user name = " + users.get(i));
+        }
+    }
+
     /*
      * 模拟从异步线程发来的更新信息
      */
diff --git a/src/org/simple/eventbus/EventBus.java b/src/org/simple/eventbus/EventBus.java
@@ -129,7 +129,9 @@ public void register(Object subscriber) {
             return;
         }
 
-        mMethodHunter.findSubcribeMethods(subscriber);
+        synchronized (this) {
+            mMethodHunter.findSubcribeMethods(subscriber);
+        }
     }
 
     /**
@@ -139,7 +141,10 @@ public void unregister(Object subscriber) {
         if (subscriber == null) {
             return;
         }
-        mMethodHunter.removeMethodsFromMap(subscriber);
+
+        synchronized (this) {
+            mMethodHunter.removeMethodsFromMap(subscriber);
+        }
 
         Log.d(getDescriptor(), "### subscriber map size = " + mSubcriberMap.size());
     }

Original file line number	Diff line number	Diff line change
`@@ -129,7 +129,9 @@ public void register(Object subscriber) {`
`129`	`129`	`return;`
`130`	`130`	`}`
`131`	`131`
`132`		`- mMethodHunter.findSubcribeMethods(subscriber);`
	`132`	`+ synchronized (this) {`
	`133`	`+ mMethodHunter.findSubcribeMethods(subscriber);`
	`134`	`+ }`
`133`	`135`	`}`
`134`	`136`
`135`	`137`	`/**`
`@@ -139,7 +141,10 @@ public void unregister(Object subscriber) {`
`139`	`141`	`if (subscriber == null) {`
`140`	`142`	`return;`
`141`	`143`	`}`
`142`		`- mMethodHunter.removeMethodsFromMap(subscriber);`
	`144`	`+`
	`145`	`+ synchronized (this) {`
	`146`	`+ mMethodHunter.removeMethodsFromMap(subscriber);`
	`147`	`+ }`
`143`	`148`
`144`	`149`	`Log.d(getDescriptor(), "### subscriber map size = " + mSubcriberMap.size());`
`145`	`150`	`}`