দ্যnotify()
ফাংশনটি একটি অপেক্ষা থ্রেড (যদি থাকে) জাগাতে ব্যবহৃত হয়। শুধুমাত্র থ্রেডগুলি যা ডেকেছেwait()
পদ্ধতি জেগে উঠবে।
জানানো হবে
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)
}
}
ব্যবহার করুনnotify()
অপেক্ষা করা থ্রেডকে জাগ্রত করার ফাংশন।
দ্যnotify()
ফাংশন অপেক্ষা সারি একটি থ্রেড জাগায়.
যখনnotify()
ফাংশন একটি থ্রেড জাগিয়ে তোলে, থ্রেড থ্রেড লক পুনরায় অর্জন করবে।
{@fun/Threads/ThreadCondition/notifyAll notifyAll}, {@fun/Threads/ThreadCondition/wait wait}, {@fun/Threads/ThreadCondition/acquire acquire}, {@fun/Threads/ThreadCondition/release release}
থ্রেড ইভেন্ট সকলকে জানানো