summaryrefslogtreecommitdiff
path: root/tests/features/test_concurrency_suite.zc
diff options
context:
space:
mode:
authorSAJJA EASWAR <eshwarsajja20@gmail.com>2026-01-25 22:59:36 +0530
committerSAJJA EASWAR <eshwarsajja20@gmail.com>2026-01-25 22:59:36 +0530
commitebc8b94baa6bc694cb4829e2eb2934a1f17fa6a1 (patch)
tree71b952ad455bf17d5bdea01472f0e2297f25eabe /tests/features/test_concurrency_suite.zc
parent863118c95caac0d69a35f6ae4d2e83844734a8a1 (diff)
parent489336b2101bf16edeec7bfc4379408eb19b936e (diff)
Merge branch 'main' into pr-109
Diffstat (limited to 'tests/features/test_concurrency_suite.zc')
-rw-r--r--tests/features/test_concurrency_suite.zc30
1 files changed, 15 insertions, 15 deletions
diff --git a/tests/features/test_concurrency_suite.zc b/tests/features/test_concurrency_suite.zc
index aa7512a..a0b571b 100644
--- a/tests/features/test_concurrency_suite.zc
+++ b/tests/features/test_concurrency_suite.zc
@@ -29,48 +29,48 @@ struct Counter {
}
test "test_async_basics" {
- var future1 = double_slowly(21);
- var future2 = add_async(10, 20);
+ let future1 = double_slowly(21);
+ let future2 = add_async(10, 20);
- var result1 = await future1;
- var result2 = await future2;
+ let result1 = await future1;
+ let result2 = await future2;
assert(result1 == 42, "Async double failed");
assert(result2 == 30, "Async add failed");
}
test "test_async_struct_return" {
- var f = make_point(5, 7);
- var p = await f;
+ let f = make_point(5, 7);
+ let p = await f;
assert(p.x == 5, "Async struct x failed");
assert(p.y == 7, "Async struct y failed");
}
test "test_async_void" {
- var f = say_hello();
+ let f = say_hello();
await f;
}
test "test_thread" {
println "Testing Concurrency...";
- var c = (Counter*)malloc(sizeof(Counter));
+ let c = (Counter*)malloc(sizeof(Counter));
c.val = 0;
c.lock = Mutex::new();
def N = 10000;
- var t1_res = Thread::spawn(fn() {
- for (var i=0; i<N; ++i) {
+ let t1_res = Thread::spawn(fn() {
+ for (let i=0; i<N; ++i) {
c.lock.lock();
c.val = c.val + 1;
c.lock.unlock();
}
});
- var t2_res = Thread::spawn(fn() {
- for (var i=0; i<N; ++i) {
+ let t2_res = Thread::spawn(fn() {
+ for (let i=0; i<N; ++i) {
c.lock.lock();
c.val = c.val + 1;
c.lock.unlock();
@@ -80,15 +80,15 @@ test "test_thread" {
assert(t1_res.is_err() == false, "T1 failed to spawn");
assert(t2_res.is_err() == false, "T2 failed to spawn");
- var t1 = t1_res.unwrap();
- var t2 = t2_res.unwrap();
+ let t1 = t1_res.unwrap();
+ let t2 = t2_res.unwrap();
t1.join();
t2.join();
println "Final Count: {c.val} (Expected {2 * N})";
- var final_val = c.val;
+ let final_val = c.val;
c.lock.free();
free(c);