async_task_sleep.swift

// RUN: %target-run-simple-swift( -target %target-swift-5.1-abi-triple %import-libdispatch -parse-as-library) | %FileCheck %s --dump-input always
// REQUIRES: executable_test
// REQUIRES: concurrency
// REQUIRES: libdispatch

// rdar://76038845
// REQUIRES: concurrency_runtime
// UNSUPPORTED: back_deployment_runtime

import _Concurrency
// FIXME: should not depend on Dispatch
import Dispatch

@available(SwiftStdlib 5.1,*)
@mainstructMain{
staticletpause=500_000_000 // 500ms

staticfunc main()async{
awaittestSleepDuration()
awaittestSleepDoesNotBlock()
awaittestSleepHuge()
}

staticfunc testSleepDuration()async{
letstart=DispatchTime.now()

awaitTask.sleep(UInt64(pause))

letstop=DispatchTime.now()

 // assert that at least the specified time passed since calling `sleep`
assert(stop >=(start +.nanoseconds(pause)))
}

staticfunc testSleepDoesNotBlock()async{
 // FIXME: Should run on main executor
lettask=detach{
print("Run first")
}

awaitTask.sleep(UInt64(pause))

print("Run second")

 // CHECK: Run first
 // CHECK: Run second
await task.get()
}

staticfunc testSleepHuge()async{
 // Make sure nanoseconds values about Int64.max don't get interpreted as
 // negative and fail to sleep.
lettask1=detach{
tryawaitTask.sleep(nanoseconds:UInt64(Int64.max)+1)
}
lettask2=detach{
tryawaitTask.sleep(nanoseconds:UInt64.max)
}

try!awaitTask.sleep(nanoseconds:UInt64(pause))

 task1.cancel()
 task2.cancel()

 // These should throw due to being canceled. If the sleeps completed then
 // the cancellation will do nothing and we won't throw, which is a failure.
do{
 _ =tryawait task1.value
fatalError("Sleep 1 completed early.")
}catch{}
do{
 _ =tryawait task2.value
fatalError("Sleep 2 completed early.")
}catch{}
}
}