fix(pmap): try not to exit abnormal as much as possible

apps/emqx/src/emqx_misc.erl

@@ -473,7 +473,14 @@ do_parallel_map(Fun, List) ->
         fun(Item) ->
             erlang:spawn_link(
                 fun() ->
-                    Parent ! {self(), Fun(Item)}
+                    Res =
+                        try
+                            {normal, Fun(Item)}
+                        catch
+                            C:E:St ->
+                                {exception, {C, E, St}}
+                        end,
+                    Parent ! {self(), Res}
                 end
             )
         end,
@@ -482,8 +489,10 @@ do_parallel_map(Fun, List) ->
     lists:foldr(
         fun(Pid, Acc) ->
             receive
-                {Pid, Result} ->
+                {Pid, {normal, Result}} ->
-                    [Result | Acc]
+                    [Result | Acc];
+                {Pid, {exception, {C, E, St}}} ->
+                    erlang:raise(C, E, St)
             end
         end,
         [],

apps/emqx/test/emqx_misc_SUITE.erl

@@ -194,8 +194,8 @@ t_pmap_timeout(_) ->
     ).
 
 t_pmap_exception(_) ->
-    ?assertExit(
+    ?assertError(
-        {foobar, _},
+        foobar,
         emqx_misc:pmap(
             fun
                 (error) -> error(foobar);