15parallel.mql 534 B

12345678910111213141516171819202122232425
  1. -- ============================================================
  2. -- parallel(N) 并发测试
  3. -- ============================================================
  4. /**
  5. scope(mql)
  6. loop(10)
  7. parallel(5)
  8. **/
  9. ;
  10. -- 10 次循环,最大并发数 5
  11. 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}))
  12. /**
  13. onerror(continue)
  14. sleep(100ms)
  15. **/
  16. ;
  17. -- 验证并发插入
  18. select count(*) from /test/aaa/test_ext where e_name=^'parallel'
  19. /**
  20. output()
  21. **/
  22. ;