ci: fix the remaining obsolete reference to time.sleep and time.usleep
parent
da05c7ed1a
commit
c37daba41d
|
@ -2576,7 +2576,7 @@ import time
|
|||
|
||||
fn task(id int, duration int, mut wg sync.WaitGroup) {
|
||||
println('task $id begin')
|
||||
time.sleep_ms(duration)
|
||||
time.wait(duration * time.millisecond)
|
||||
println('task $id end')
|
||||
wg.done()
|
||||
}
|
||||
|
@ -3841,7 +3841,7 @@ fn print_message() {
|
|||
fn main() {
|
||||
for {
|
||||
print_message()
|
||||
time.sleep_ms(500)
|
||||
time.wait(500 * time.millisecond)
|
||||
}
|
||||
}
|
||||
```
|
||||
|
|
|
@ -31,10 +31,10 @@ import benchmark
|
|||
|
||||
mut b := benchmark.start()
|
||||
// your code section 1 ...
|
||||
time.sleep_ms(1500)
|
||||
time.wait(1500 * time.millisecond)
|
||||
b.measure('code_1')
|
||||
// your code section 2 ...
|
||||
time.sleep_ms(500)
|
||||
time.wait(500 * time.millisecond)
|
||||
b.measure('code_2')
|
||||
```
|
||||
|
||||
|
|
|
@ -107,7 +107,7 @@ pub fn (mut ctx Context) run() ? {
|
|||
init_called = true
|
||||
}
|
||||
if sleep_len > 0 {
|
||||
time.usleep(sleep_len)
|
||||
time.wait(sleep_len * time.microsecond)
|
||||
}
|
||||
if !ctx.paused {
|
||||
sw.restart()
|
||||
|
|
|
@ -8,7 +8,7 @@ mut:
|
|||
fn (shared x St) f(shared z St) {
|
||||
for _ in 0 .. reads_per_thread {
|
||||
rlock x { // other instances may read at the same time
|
||||
time.sleep_ms(1)
|
||||
time.wait(time.millisecond)
|
||||
assert x.a == 7 || x.a == 5
|
||||
}
|
||||
}
|
||||
|
@ -65,10 +65,10 @@ fn test_shared_lock() {
|
|||
for i in 0 .. writes {
|
||||
lock x { // wait for ongoing reads to finish, don't start new ones
|
||||
x.a = 17 // this value should never be read
|
||||
time.sleep_ms(50)
|
||||
time.wait(50 * time.millisecond)
|
||||
x.a = if (i & 1) == 0 { 7 } else { 5 }
|
||||
} // now new reads are possible again
|
||||
time.sleep_ms(20)
|
||||
time.wait(20 * time.millisecond)
|
||||
}
|
||||
// wait until all read threads are finished
|
||||
for finished := false; true; {
|
||||
|
@ -80,6 +80,6 @@ fn test_shared_lock() {
|
|||
if finished {
|
||||
break
|
||||
}
|
||||
time.sleep_ms(100)
|
||||
time.wait(100 * time.millisecond)
|
||||
}
|
||||
}
|
||||
|
|
|
@ -9,7 +9,7 @@ mut:
|
|||
fn (shared x St) f(shared z St) {
|
||||
for _ in 0 .. reads_per_thread {
|
||||
rlock x { // other instances may read at the same time
|
||||
time.sleep_ms(1)
|
||||
time.wait(time.millisecond)
|
||||
assert x.a == 7 || x.a == 5
|
||||
}
|
||||
}
|
||||
|
@ -63,11 +63,11 @@ a: 5
|
|||
for i in 0..writes {
|
||||
lock x { // wait for ongoing reads to finish, don't start new ones
|
||||
x.a = 17 // this value should never be read
|
||||
time.sleep_ms(50)
|
||||
time.wait(50* time.millisecond)
|
||||
x.a = if (i & 1) == 0 {
|
||||
7} else {5}
|
||||
} // now new reads are possible again
|
||||
time.sleep_ms(20)
|
||||
time.wait(20*time.millisecond)
|
||||
}
|
||||
// wait until all read threads are finished
|
||||
for finished:=false;; {
|
||||
|
@ -79,6 +79,6 @@ for finished:=false;; {
|
|||
if finished {
|
||||
break
|
||||
}
|
||||
time.sleep_ms(100)
|
||||
time.wait(100*time.millisecond)
|
||||
}
|
||||
}
|
||||
|
|
|
@ -305,7 +305,7 @@ pub fn parse_files(paths []string, table &table.Table, pref &pref.Preferences, g
|
|||
for _ in 0 .. nr_cpus - 1 {
|
||||
go q.run()
|
||||
}
|
||||
time.sleep_ms(1000)
|
||||
time.wait(time.second)
|
||||
println('all done')
|
||||
return q.parsed_ast_files
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue