Objetos condicionais, usados para sincronização de múltiplos fios.
notify()
```javascript
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)
}
}
Utilizaçãonotify()
A função desperta o fio pendente.
notify()
A função acorda um thread na fila de espera.
notify()
Quando a função desperta um fio, este retoma o fecho do fio.
{@fun/Threads/ThreadCondition/notifyAll notifyAll}, {@fun/Threads/ThreadCondition/wait wait}, {@fun/Threads/ThreadCondition/acquire acquire}, {@fun/Threads/ThreadCondition/release release}
notifyAll()
A função acorda todas as linhas pendentes.
Avise a todos
Exemplos para referênciaThreadCondition.notify()
O conteúdo do capítulo.
notifyAll()
A função desperta todas as linhas pendentes individualmente, e as linhas despertas recuperam o bloco do fio.
{@fun/Threads/ThreadCondition/notify notify}, {@fun/Threads/ThreadCondition/wait wait}, {@fun/Threads/ThreadCondition/acquire acquire}, {@fun/Threads/ThreadCondition/release release}
wait()
A função é usada para deixar o thread em espera sob certas condições de design.
Espere.
Exemplos para referênciaThreadCondition.notify()
O conteúdo do capítulo.
wait()
A função liberta o cadeado do fio e retoma o cadeado do fio quando é despertada.
{@fun/Threads/ThreadCondition/notify notify}, {@fun/Threads/ThreadCondition/notifyAll notifyAll}, {@fun/Threads/ThreadCondition/acquire acquire}, {@fun/Threads/ThreadCondition/release release}
acquire()
A função é usada para solicitar o bloqueio de um thread.
Adquirir (((
Exemplos para referênciaThreadCondition.notify()
O conteúdo do capítulo.
Em usowait()
Antes disso, era necessário solicitar o bloqueio de thread 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}
release()
A função é usada para liberar o bloqueio de um fio.
libertação
Exemplos para referênciaThreadCondition.notify()
O conteúdo do capítulo.
Em usowait()
A partir daí, é necessário liberar o 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/acquire acquire}
ThreadEvent ThreadDict