1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
//================================================================ /** * @packageDocumentation * @module std   *///================================================================import { ILockable } from "../base/thread/ILockable";
/** * Sleep for time span. *  * @param ms The milliseconds to sleep. */export function sleep_for(ms: number): Promise<void>{    return new Promise<void>(resolve =>    {        setTimeout(resolve, ms);    });}
/** * Sleep until time expiration. *  * @param at The time point to wake up. */export function sleep_until(at: Date): Promise<void>{    let now: Date = new Date();    let ms: number = at.getTime() - now.getTime(); // MILLISECONDS TO WAIT
    return sleep_for(ms); // CONVERT TO THE SLEEP_FOR}
/** * Lock multiple mutexes. *  * @param items Items to lock. */export async function lock(...items: Pick<ILockable, "lock">[]): Promise<void>{    let promises: Promise<void>[] = [];    for (let mtx of items)        promises.push(mtx.lock());
    await Promise.all(promises);}
/** * Try lock mutexes. *  * @param items Items to try lock. * @return Index of mutex who failed to lock. None of them're failed, then returns `-1`. */export async function try_lock(...items: Pick<ILockable, "try_lock">[]): Promise<number>{    for (let i: number = 0; i < items.length; ++i)        if (await items[i].try_lock() === false)            return i;
    return -1;}