MATLAB: Implementation of array of queues

arrayMATLABqueue

Since matlab does not support queues, I am using arrays to handle the queueing functionality.

I have to implement an array of queues, which each queue of different length. 2D arrays in matlab support only matrices, hence should be of same no. of elements in each queue which is not my requirement.

I imported Java implementation of linkedlist, but it does not support struct or a class object. The element to be added into a queue is a struct or a class object.

How can I handle this in the most efficient way?

Best Answer

Standard arrays must be rectangular. However cell arrays are the perfect solution.

C = {1:3, 1:5,1:8}
C =
  1×3 cell array
    {1×3 double}    {1×5 double}    {1×8 double}
>> C{:}
ans =
     1     2     3
ans =
     1     2     3     4     5
ans =
     1     2     3     4     5     6     7     8

You create and index them using curly braces, thus {}.

C{3}
ans =
     1     2     3     4     5     6     7     8

And a cell array can contain anything at all, including structs.

Of course, an array of structs is also possible, and a struct can act as a container for anything too.

Related Solutions

MATLAB: Save() and load() Variables in Object of correct Class

OK, got it:

ws = load('workspace6.mat');
map2 = ws.map;
strg2 = ws.strg;

MATLAB: Simevents: change the server capacity during simulation

Hi Kar,

You are correct, Entity Server does not allow for changing the capacity at run-time. Resource Pool block allows changing the resource amount at run-time through a signal port, but it only allows incrementing the available resources in the pool. And not the other way around.

For the variable capacity server, you can try using a MATLAB discrete-event system block and try including a queue of infinite capacity. You can then control whether to allow or disallow an entity from entering the queue by implementing the testEntry method. That way you can control the capacity at run-time. For example you can do something like the following:

function isAllowed = testEntry(obj, storage, ~, ~)
    % Specifies whether entities are allowed into the storage
    isAllowed = obj.mCurrentOccupancy <= obj.mCurrentCapacity;
end
function events = entry(obj, storage, ~, ~)
    % Increment the current occupancy

    obj.mCurrentOccupancy = obj.mCurrentOccupancy + 1;
    
    % Post a forward event after service-time

    events = obj.eventForward('output', 1, obj.mServiceTime);
end
function events = exit(obj, ~, ~, ~)
    % Decrement the current occupancy
    obj.mCurrentOccupancy = obj.mCurrentOccupancy - 1;
    
    if(obj.mCurrentOccupancy < obj.mCurrentCapacity)
        % Since there is room for entities, check if any entity
        % wishes to enter the block.
        events = [events obj.eventTestEntry(1)];
    end
end

In the above example, you can define mCurrentCapacity as a tunable parameter (not recommended). If the capacity decreases, then the new capacity would kick in only after the delta amount of entities would have left the block. You can have a more complex policy based on your particular use-case.

One caveat with the above piece of code is that, when the capacity of the server changes (increases), we need to test for entry (by posting a testEntry event), as there might be entities that were previously blocked out. But there is no way to do that since, we cannot associate an event when a tunable parameter changes. The best way would be to increment the server capacity by using another entity port. This other port would accept an entity that specifies the new capacity. This would enable us to return a testEntry event from the entry method.

function events = entry(obj, storage, ~, ~)
    % Increment the current occupancy
    if storage == 1
        % Book-keeping
        obj.mCurrentOccupancy = obj.mCurrentOccupancy + 1;
        
        % Post a forward event after service-time
        events = obj.eventForward('output', 1, obj.mServiceTime);
    elseif storage == 2
        obj.mCurrentCapacity = entity.data; % Assuming anonymous entity
        % Omitting checks for brevity
        events = [events obj.eventTestEntry(1)];
    end
end

An alternative to using DES block would be to use an infinite capacity server and use an entity gate to control the number of entities entering the server. The gate could be operated by adding some logic which would be driven by the statistics ports of the Entity Server.

Hope this helps!

- Krishna

Best Answer

Related Solutions

MATLAB: Save() and load() Variables in Object of correct Class

MATLAB: Simevents: change the server capacity during simulation

Related Question