New threads (NEWTHREAD, NEWEXECUTOR)

The new thread operator allows you to execute an action in a thread other than the current one.

By default, an action is executed once in a new thread, immediately after the creation of this thread. However, if necessary, the action can be executed with a defined delay and/or performed continuously at a specified time interval.

The action can also be executed in a new thread on behalf of a specified connection (for example, some user). In this case, user interaction operators may be used inside the action, including form opening in interactive view (by default, when you use these operators, the platform will throw an error).

The delay, interval and connection in this operator are defined as certain properties.

New thread pool

Sometimes the number of simultaneously running threads must be limited to a certain value (as a rule, this is done if the executed actions are not critical and the moment in time when they are completed is not so important). To implement this functionality, the platform has an operator for creating a new thread pool. This allows the operator to perform an action in such a way that all new threads generated inside this action come into this thread pool, which at the same time can include no more than a specified number of threads.

The number of threads is defined as a property.

Language

To declare an action that executes another action in a new thread, use the NEWTHREAD operator. To perform an action in a new thread pool, use the NEWEXECUTOR operator.

Examples

testNewThread ()  {
    //Showing messages 'Message' to all
    FOR user(Connection conn) AND connectionStatus(conn) == ConnectionStatus.connectedConnection AND conn != currentConnection() DO {
        NEWTHREAD MESSAGE 'Message'; CONNECTION conn;
    }

    //Execution of the 'action' action with a frequency of 10 seconds and a delay of 5 seconds
    NEWTHREAD MESSAGE 'Hello World'; SCHEDULE PERIOD 10000 DELAY 5000;
}

testExecutor  {
    NEWEXECUTOR {
        FOR id(Sku s) DO {
            NEWTHREAD {
                NEWSESSION {
                    name(s) <- STRING[20](id(s)); // writing the code into the name in 10 threads
                    APPLY;
                }
            }
        }
    } THREADS 10;
}