// In this example our state will be owned by a single thread. This will guarantee 
// that the data is never corrupted with concurrent access. In order to read or 
// write that state, other threads will send messages to the owning thread and 
// receive corresponding replies. These readOp and writeOp structures encapsulate 
// those requests and a way for the owning thread to respond.

function [value] = readOp(key)
    value = state(key);
endfunction

function writeOp(key, val)
    state(key) = val;
endfunction

// Initialize the state
state = struct();

// As before we'll count how many operations we perform.
readOps = 0;
writeOps = 0;

// This function simulates the state-owning thread
function stateManager()
    while %T
        // In Scilab, we don't have a built-in select statement for channels
        // So we'll simulate it with a simple if-else structure
        if ~isempty(reads)
            key = reads(1);
            reads(1) = [];
            respq($+1) = readOp(key);
        elseif ~isempty(writes)
            [key, val] = writes(1);
            writes(1) = [];
            writeOp(key, val);
            respq($+1) = %T;
        end
    end
endfunction

// Start the state manager in a separate thread
execstr('stateManager()', 'errcatch', 'n');

// Simulate multiple read operations
for i = 1:100
    execstr(['
        while %T
            key = floor(rand() * 5) + 1;
            reads($+1) = key;
            response = respq(1);
            respq(1) = [];
            readOps = readOps + 1;
            sleep(1);
        end
    '], 'errcatch', 'n');
end

// Simulate multiple write operations
for i = 1:10
    execstr(['
        while %T
            key = floor(rand() * 5) + 1;
            val = floor(rand() * 100) + 1;
            writes($+1) = [key, val];
            response = respq(1);
            respq(1) = [];
            writeOps = writeOps + 1;
            sleep(1);
        end
    '], 'errcatch', 'n');
end

// Let the threads work for a second.
sleep(1000);

// Finally, capture and report the op counts.
disp("readOps: " + string(readOps));
disp("writeOps: " + string(writeOps));