16fork_wait.mql 826 B

12345678910111213141516171819202122232425262728293031323334
  1. -- ============================================================
  2. -- fork(G) 和 wait(G) 模式测试
  3. -- ============================================================
  4. -- 1. fork 一个分组执行
  5. insert into /test/aaa/test_ext (e_name, e_value, e_text) values ('fork_a_1', 100, 'fork group a - 1')
  6. /**
  7. fork(group_a)
  8. **/
  9. ;
  10. -- 2. fork 另一个分组
  11. insert into /test/aaa/test_ext (e_name, e_value, e_text) values ('fork_a_2', 200, 'fork group a - 2')
  12. /**
  13. fork(group_a)
  14. **/
  15. ;
  16. -- 3. wait 等待 group_a 完成
  17. /**
  18. wait(group_a)
  19. **/
  20. ;
  21. -- 等待分组完成后继续执行
  22. insert into /test/aaa/test_ext (e_name, e_value, e_text) values ('after_wait_a', 999, 'after wait group_a')
  23. ;
  24. -- 4. 验证 fork/wait 结果
  25. select e_name, e_value from /test/aaa/test_ext where e_name=^'fork_a' or e_name='after_wait_a'
  26. /**
  27. output()
  28. **/
  29. ;