-- ============================================================
-- 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_', <mqli>), <mqli>, concat('parallel loop mqli=', <mqli>))
/**
sleep(100ms)
**/
;

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