临时提交

yunchai

2023-10-07 160249d574bc6776d347eb7c046ee2d759af8c16

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
Quintiq file version 2.0
#parent: #root
Method DoFinalize (LibOpt_Task task, output Boolean hascreatedstream_o) as stream[JSON]
{
  Description:
  [*
    This method makes sure that the `DoFinalizeCurrentComponent` method is executed in the right order. This method should be executed for all components.
    When a `LibOpt_TaskTransporterOneTransaction` is used to execute a component, then the execution of the `DoFinalize` method can be delayed. When this happens, the `DoFinalize` method is called in a single transaction together with the `DoFinalize` methods of other components.
    We want to finalize the component that is the most downstream first. 
    Therefore, this method ensures that the `DoFinalizeCurrentComponent` method is called first for the most downstream component for which the `DoFinalizeCurrentComponent` method hasn't been excuted yet.
  *]
  TextBody:
  [*
    // evr3 Jun-16-2020 (created)
    
    streamJSON := stream[JSON]::Success();
    
    // If this task has any subtasks, then we call DoFinalize for each of these subtasks.
    // Note: A subtask can only exist if DoFinalize/DoFinalizeCurrentComponent has not been executed yet for this subtask, 
    // because executing DoFinalizeCurrentComponent for a (sub)task results in the deletion of the (sub)task.
    traverse( task, Children, subtask, not hascreatedstream_o )
    {  
      streamJSON := subtask.Component().DoFinalize( subtask, hascreatedstream_o );
      // If calling DoFinalize for a subtask did not create a stream, then the subtask is deleted when DoFinalize finished executing for that subtask.
      // If calling DoFinalize for a subtask did create a stream, then hascreatedstream_o will be true. The subtask will only be deleted after this stream terminates.
      // We therefore escape this traverse and wait until the stream is terminated.
    }
    
    if( not hascreatedstream_o )
    {
      // If none of the subtasks created a stream, then we execute DoFinalizeCurrentComponent, which performs the actual finalize actions for this component. 
      // Note: We will call DoFinalizeCurrentComponent eventually for this component, because if we did create a stream, then we will call DoFinalize again in the 'else'-block below.
      streamJSON := this.DoFinalizeCurrentComponent( task, hascreatedstream_o ); 
    }
    else
    {
      // If we did create a stream, then we wait until we have resolved this stream (which will delete a subtask). Then we call DoFinalize again. 
      streamJSON := streamJSON->|this->DoFinalize( task ); 
    }
    
    return streamJSON;
  *]
  InterfaceProperties { Accessibility: 'Module' }
}