16fork_wait.mql 865 B

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