ParallelOC

local event = require("event")

local function create( first, ... )
    if first ~= nil then
        return coroutine.create(first), create( ... )
    end
    return nil
end

local function runUntilLimit( _routines, _limit )
    local count = #_routines
    local living = count

    local tFilters = {}
    local eventData = {}
    while true do
        for n=1,count do
            local r = _routines[n]
            if r then
                if tFilters[r] == nil or tFilters[r] == eventData[1] or eventData[1] == "terminate" then
                    local ok, param = coroutine.resume( r, table.unpack(eventData) )
                    if not ok then
                        error( param )
                    else
                        tFilters[r] = param
                    end
                    if coroutine.status( r ) == "dead" then
                        _routines[n] = nil
                        living = living - 1
                        if living <= _limit then
                            return n
                        end
                    end
                end
            end
        end
        for n=1,count do
            local r = _routines[n]
            if r and coroutine.status( r ) == "dead" then
                _routines[n] = nil
                living = living - 1
                if living <= _limit then
                    return n
                end
            end
        end
        eventData = { event.pull() }
    end
end
parallelApi={
waitForAny = function ( ... )
    local routines = { create( ... ) }
    return runUntilLimit( routines, #routines - 1 )
end,

waitForAll = function( ... )
    local routines = { create( ... ) }
    runUntilLimit( routines, 0 )
end
}
return parallelApi