forked from LeenkxTeam/Kmake
65 lines
1.9 KiB
JavaScript
65 lines
1.9 KiB
JavaScript
// Copyright 2024 the V8 project authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style license that can be
|
|
// found in the LICENSE file.
|
|
//
|
|
// Flags: --harmony-struct --allow-natives-syntax
|
|
|
|
'use strict';
|
|
|
|
if (this.Worker) {
|
|
(function TestTimeout() {
|
|
let workerScript = `onmessage = function({data:msg}) {
|
|
let {mutex, box, cv, cv_mutex} = msg;
|
|
Atomics.Mutex.lock(mutex, function() {
|
|
Atomics.Mutex.lock(cv_mutex, function() {
|
|
// Atomics.Condition.wait releases cv_mutex but not mutex.
|
|
postMessage("lock acquired");
|
|
Atomics.Condition.wait(cv, cv_mutex);
|
|
});
|
|
});
|
|
postMessage("done");
|
|
};
|
|
postMessage("started");`;
|
|
let worker = new Worker(workerScript, {type: 'string'});
|
|
|
|
assertEquals('started', worker.getMessage());
|
|
|
|
let mutex = new Atomics.Mutex;
|
|
let cv = new Atomics.Condition;
|
|
let cv_mutex = new Atomics.Mutex;
|
|
let msg = {mutex, cv, cv_mutex};
|
|
worker.postMessage(msg);
|
|
assertEquals('lock acquired', worker.getMessage());
|
|
assertFalse(Atomics.Mutex.tryLock(mutex, function() {}).success);
|
|
|
|
let thenResolved = false;
|
|
let lockPromise = Atomics.Mutex.lockAsync(mutex, () => {
|
|
return 42;
|
|
});
|
|
// There is one waiter for mutex in this isolate's async waiter list.
|
|
assertEquals(1, %AtomicsSychronizationNumAsyncWaitersInIsolateForTesting());
|
|
|
|
lockPromise.then((result) => {
|
|
thenResolved = true;
|
|
assertEquals(true, result.success);
|
|
assertEquals(42, result.value);
|
|
});
|
|
|
|
let cv_promise = Atomics.Mutex.lockAsync(cv_mutex, () => {
|
|
Atomics.Condition.notify(cv, 1);
|
|
});
|
|
|
|
cv_promise.then((result) => {
|
|
assertEquals(true, result.success);
|
|
assertEquals('done', worker.getMessage());
|
|
});
|
|
|
|
let asyncLoop = () => {
|
|
if (!thenResolved) {
|
|
setTimeout(asyncLoop, 0);
|
|
}
|
|
};
|
|
asyncLoop();
|
|
})();
|
|
}
|