diff --git a/apps/emqx_ft/src/emqx_ft_async_reply.erl b/apps/emqx_ft/src/emqx_ft_async_reply.erl index f33558434..7ac4c527f 100644 --- a/apps/emqx_ft/src/emqx_ft_async_reply.erl +++ b/apps/emqx_ft/src/emqx_ft_async_reply.erl @@ -55,8 +55,15 @@ -spec create_tables() -> ok. create_tables() -> - _ = ets:new(?MON_TAB, [named_table, public, ordered_set]), - _ = ets:new(?PACKET_TAB, [named_table, public, ordered_set]), + EtsOptions = [ + named_table, + public, + ordered_set, + {read_concurrency, true}, + {write_concurrency, true} + ], + _ = ets:new(?MON_TAB, EtsOptions), + _ = ets:new(?PACKET_TAB, EtsOptions), ok. -spec register(packet_id(), mon_ref(), timer_ref()) -> ok.