-- ============================================================
-- parallel(N) 并发测试
-- ============================================================

/**
scope(mql)
loop(10)
parallel(5)
**/
;

-- 10 次循环，最大并发数 5
insert into /test/aaa/test_ext (e_name, e_value, e_text) values (concat('parallel_', {%d,mqli}), {%d,mqli}, concat('parallel loop mqli=', {%d,mqli}))
/**
onerror(continue)
sleep(100ms)
**/
;

-- 验证并发插入
select count(*) from /test/aaa/test_ext where e_name=^'parallel'
/**
output()
**/
;