home *** CD-ROM | disk | FTP | other *** search
- AbtThreadsApp becomeDefault!
-
- !AbtThreadManager class privateMethods !
-
- dispatchMessage: reqId
-
- | procSynch reply |
-
- procSynch := self procSynchFor: reqId.
- (procSynch isNil) ifTrue: [
- ^self releaseCompletedMessages
- ].
- (reply := procSynch message) isUndefined ifTrue: [
- ^self releaseCompletedMessages
- ].
- reply messageType == AbtReplyMessage ifFalse: [
- ^self releaseCompletedMessages
- ].
- procSynch signal.
- Processor yield.
- !
-
- releaseCompletedMessages
-
- | request |
- ProcessDictionaryLock abtWait.
- self processDictionary do: [: procSync |
- (request := procSync message) isNil ifFalse: [
- request isUndefined ifFalse: [
- request messageType == AbtReplyMessage ifTrue: [
- procSync signal
- ]
- ]
- ]
- ].
- ProcessDictionaryLock abtSignal.! !