Coroutines for PB [Windows / Linux]
Posted: Sun Feb 16, 2025 9:39 pm
Hi,
This has been a weekend project so it will need more documentation and testing, i wanted coroutines in PB.
Coroutines are resumable functions that can be paused and resumed, something like the async / await pattern.
I used libaco for linux:
https://github.com/hnes/libaco
And the fibers api for Windows:
https://learn.microsoft.com/en-us/windo ... ead/fibers
libaco should compile for macos but i haven't tried it.
Project at github:
https://github.com/omegakode/PBCoroutines
A coroutine procedure accepts a single paramter, the coroutine handle, that you use with the co_*() functions, a coroutine must be always exited with co_exit().
See example:
This has been a weekend project so it will need more documentation and testing, i wanted coroutines in PB.
Coroutines are resumable functions that can be paused and resumed, something like the async / await pattern.
I used libaco for linux:
https://github.com/hnes/libaco
And the fibers api for Windows:
https://learn.microsoft.com/en-us/windo ... ead/fibers
libaco should compile for macos but i haven't tried it.
Project at github:
https://github.com/omegakode/PBCoroutines
A coroutine procedure accepts a single paramter, the coroutine handle, that you use with the co_*() functions, a coroutine must be always exited with co_exit().
See example:
Code: Select all
;PBCoroutines_Test.pb
EnableExplicit
XIncludeFile "PBCoroutines.pb"
Procedure.l co_function(*co.co_handle)
Protected.l x
Debug "co_function start"
x = 0
For x = 1 To 5
Debug "co_function " + Str(x)
co_put_arg(*co, x)
co_yield(*co) ;switch to main
Next
Debug "co_function end"
co_exit(*co)
EndProcedure
Procedure main()
Protected.co_handle *mainCo, *co
co_lib_init() ;init lib
co_thread_init() ;init thread
;main coroutine
*mainCo = co_create(#Null, #Null, #Null)
;child coroutine
*co = co_create(*mainCo, @co_function(), 0)
While Not co_ended(*co)
co_resume(*co) ;switch to co_function
If Not co_ended(*co) ;check if ended after last resume
Debug "main " + Str(co_get_arg(*co))
EndIf
Wend
Debug "main done"
co_destroy(*co)
co_lib_shutdown() ;close lib
EndProcedure
main()
