Would you post an example of how you are utilizing this lib?PolyVector wrote:Hello everyone,
I created a tiny lib for my own use that syncronizes threads...
I figured some of you may be interested... It is VERY simple to use and only has 5 commands
Tell me whatcha think!
http://www.skunksoft.com/Downloads/SS_ThreadSync.zip1) hResource=AddThreadResource() ;Creates an ID to reference a shared 'Resource'... Call this at the beginning of your program
2) OpenThreadResource(hResource) ;Waits until the 'Resource' is available, then makes it unavailable to other threads...
3) OpenThreadResourceWithin(hResource,ResourceTimeout) ;Same as above, only w/ a timeout...
4) CloseThreadResource(hResource) ;Makes a 'Resource' available to other threads...
5) DeleteThreadResource(hResource) ;Free's the 'Resource' handle... Call this at the end of you program
If you need help, visit our forums:
http://www.skunksoft.com/forums/
Sorry if the site's a complete mess, we're undergoing massive reorganization
Code: Select all
;-Skunksoft ThreadSync Lib Test
;-Created by PolyVector...
;/This example shows the use of every command in the library so far...
;/MyAddThread() does the useless task of adding 1 to a global variable
;/MySubtractThread() does the useless task of subtracting 1 from a global variable
;/Run with the Debugger On to watch the threads fight eachother :)
;ThreadSyncInit() ;Initializes the SS_ThreadSync Engine
;ThreadSyncExit() ;Exits the SS_ThreadSync Engine
;hResource=AddThreadResource() ;Creates an ID to reference a shared 'Resource'... Call this at the beginning of your program
;OpenThreadResource(hResource) ;Waits until the 'Resource' is available, then makes it unavailable to other threads...
;OpenThreadResourceWithin(hResource,ResourceTimeout) ;Same as above, only with a timeout...
;CloseThreadResource(hResource) ;Makes a 'Resource' available to other threads...
;DeleteThreadResource(hResource) ;Free's the 'Resource' handle... Call this at the end of you program
;SendThreadMessage(RecipientID,MessageID) ;Sends a Message to the RecipientID
;GetThreadMessage(RecipientID) ;Retrieves the MessageID sent to the RecipientID
;-
ThreadSyncInit();The Lib version now requires you to call Init and Exit procedures
Enumeration ;Recipients for ThreadMessages :)
#MyAddThread
#MySubtractThread
EndEnumeration
Enumeration 1 ;MessageID's to send (can't use 0 for messages)
#LetsQuit
EndEnumeration
;Make some global variables for testing...
Global LongVariable.l
Global StringVariable$
;Create a 'Resource' to protect the variables...
Global MyResource.l
MyResource=AddThreadResource()
Procedure MyAddThread(RecipientID)
Repeat
Select GetThreadMessage(RecipientID);Check for any messages send to this thread
Case #LetsQuit
Debug "Bye Bye From MyAddThread()"
ProcedureReturn
EndSelect
OpenThreadResource(MyResource) ;Wait for MyResource to become available
LongVariable=LongVariable+1
StringVariable$=Str(LongVariable)
Debug "+1 = "+StringVariable$
CloseThreadResource(MyResource) ;Free up MyResource for other threads...
ForEver
EndProcedure
Procedure MySubtractThread(RecipientID)
Repeat
Select GetThreadMessage(RecipientID);Check for any messages send to this thread
Case #LetsQuit
Debug "Bye Bye From MySubtractThread()"
ProcedureReturn
EndSelect
If OpenThreadResourceWithin(MyResource,500) ;Wait up to 500ms for MyResource to be available
LongVariable=LongVariable-1
StringVariable$=Str(LongVariable)
Debug "-1 = "+StringVariable$
CloseThreadResource(MyResource) ;Free up MyResource for other threads...
Else
;"We Timed Out... Let's do something else for now :)"
EndIf
ForEver
EndProcedure
If OpenWindow(0,0,0,80,60,#PB_Window_SystemMenu,"ThreadSync Test")
hMyAddThread=CreateThread(@MyAddThread(),#MyAddThread);Tell the new thread it's RecipientID :)
hMySubtractThread=CreateThread(@MySubtractThread(),#MySubtractThread);Tell the new thread it's RecipientID :)
Repeat:Until WaitWindowEvent()=#wm_close
CloseWindow(0)
SendThreadMessage(#MyAddThread,#LetsQuit);Tell MyAddThread() we want to quit
SendThreadMessage(#MySubtractThread,#LetsQuit);Tell MySubtractThread() we want to quit
WaitThread(hMyAddThread);Wait for thread to exit
WaitThread(hMySubtractThread);Wait for thread to exit
Debug "Quit"
DeleteThreadResource(MyResource);Delete the MyResource handle
ThreadSyncExit();The Lib version now requires you to call Init and Exit procedures
EndIfVery kewl, thanks for the research. I will have more questions later..PolyVector wrote:Yup
I'll try to come up with some better examples/docs...
I'm usually very busy tho'
