ThreadCondição

Objeto de condição, utilizado para sincronização multi-thread.

Notificar

Onotify()A função é usada para acordar um tópico em espera (se houver).wait()O método vai despertar.

Notificar

function consumer(dict, condition) {
    while (true) {
        condition.acquire()
        while (dict.get("array").length == 0) {
            Log(threading.currentThread().name(), "wait()...", ", array:", dict.get("array"))
            condition.wait()
        }
        var arr = dict.get("array")
        var num = arr.shift()
        Log(threading.currentThread().name(), ", num:", num, ", array:", arr, "#FF0000")
        dict.set("array", arr)
        Sleep(1000)
        condition.release()
    }
}

function main() {
    var condition = threading.Condition()
    var dict = threading.Dict()
    dict.set("array", [])
    var t1 = threading.Thread(consumer, dict, condition)
    var t2 = threading.Thread(consumer, dict, condition)
    var t3 = threading.Thread(consumer, dict, condition)
    Sleep(1000)
    var i = 0
    while (true) {
        condition.acquire()
        var msg = ""
        var arr = dict.get("array")
        var randomNum = Math.floor(Math.random() * 5) + 1
        if (arr.length >= 3) {
            condition.notifyAll()
            msg = "notifyAll"
        } else {
            arr.push(i)
            dict.set("array", arr)
            if (randomNum > 3 && arr.length > 0) {
                condition.notify()
                msg = "notify"
            } else {
                msg = "pass"
            }
            i++
        }

        Log(_D(), "randomNum:", randomNum, ", array:", arr, ", msg:", msg)
        condition.release()
        Sleep(1000)
    }
}

Utilize onotify()Função para acordar o fio de espera.

Onotify()Função acorda um fio na fila de espera.

Quando onotify()Função acorda um fio, o fio vai recuperar o bloqueio do fio.

{@fun/Threads/ThreadCondition/notifyAll notifyAll}, {@fun/Threads/ThreadCondition/wait wait}, {@fun/Threads/ThreadCondition/acquire acquire}, {@fun/Threads/ThreadCondition/release release}

Notificar a todos

OnotifyAll()A função acorda todos os fios em espera.

Avise a todos

Por favor, consulte oThreadCondition.notify()secção para exemplos.

OnotifyAll()A função acorda todos os fios em espera um por um, e os fios despertados recuperam o bloqueio do fio.

{@fun/Threads/ThreadCondition/notify notify}, {@fun/Threads/ThreadCondition/wait wait}, {@fun/Threads/ThreadCondition/acquire acquire}, {@fun/Threads/ThreadCondition/release release}

- Espera.

Owait()A função é usada para fazer um fio esperar sob certas condições projetadas.

Espere.

Por favor, consulte oThreadCondition.notify()secção para exemplos.

Owait()A função liberta o bloqueio do fio e recupera o bloqueio do fio quando acordado.

{@fun/Threads/ThreadCondition/notify notify}, {@fun/Threads/ThreadCondition/notifyAll notifyAll}, {@fun/Threads/ThreadCondition/acquire acquire}, {@fun/Threads/ThreadCondition/release release}

adquire

Oacquire()A função é utilizada para solicitar um bloqueio (bloqueio) do fio.

Adquirir (((

Por favor, consulte oThreadCondition.notify()secção para exemplos.

Antes de utilizarwait(), você precisa solicitar o bloqueio de thread (bloqueio) do objeto de condição atual.

{@fun/Threads/ThreadCondition/notify notify}, {@fun/Threads/ThreadCondition/notifyAll notifyAll}, {@fun/Threads/ThreadCondition/wait wait}, {@fun/Threads/ThreadCondition/release release}

libertação

Orelease()A função é utilizada para liberar um bloqueio de fio (desbloqueio).

libertação

Por favor, consulte oThreadCondition.notify()secção para exemplos.

Após utilizaçãowait(), precisamos liberar o thread lock (desbloquear) do objeto de condição atual.

{@fun/Threads/ThreadCondition/notify notify}, {@fun/Threads/ThreadCondition/notifyAll notifyAll}, {@fun/Threads/ThreadCondition/wait wait}, {@fun/Threads/ThreadCondition/acquire acquire}

ThreadEvent ThreadDict