--- a/BackgroundQueueProcessingJob.st Wed Aug 03 16:43:28 2011 +0200
+++ b/BackgroundQueueProcessingJob.st Wed Aug 03 16:43:30 2011 +0200
@@ -65,16 +65,17 @@
!BackgroundQueueProcessingJob methodsFor:'adding & removing'!
add: object
-
"includes: is not synchronized, but should not harm"
queueAccessLock critical:[
- (queue includes: object)
- ifFalse:[queue add: object].
- self start].
+ (queue includes: object)
+ ifFalse:[queue add: object].
+ self start
+ ].
"Created: / 28-04-2011 / 20:40:29 / Jan Vrany <jan.vrany@fit.cvut.cz>"
"Modified: / 18-05-2011 / 23:30:28 / Jan Vrany <jan.vrany@fit.cvut.cz>"
+ "Modified (format): / 03-08-2011 / 16:43:01 / cg"
! !
!BackgroundQueueProcessingJob methodsFor:'initialization'!
@@ -96,16 +97,19 @@
| item |
[
- item := nil.
- queueAccessLock critical:
- [queue isEmpty ifFalse:[item := queue removeFirst]].
- item isNil ifFalse:
- [self processItem: item].
- item notNil.
+ item := nil.
+ queueAccessLock critical:[
+ queue isEmpty ifFalse:[item := queue removeFirst]
+ ].
+ item isNil ifFalse:[
+ self processItem: item
+ ].
+ item notNil.
] whileTrue
"Created: / 28-04-2011 / 20:36:35 / Jan Vrany <jan.vrany@fit.cvut.cz>"
"Modified: / 18-05-2011 / 23:30:19 / Jan Vrany <jan.vrany@fit.cvut.cz>"
+ "Modified (format): / 03-08-2011 / 16:43:21 / cg"
!
processItem: item
@@ -118,7 +122,7 @@
!BackgroundQueueProcessingJob class methodsFor:'documentation'!
version_CVS
- ^ '$Header: /cvs/stx/stx/libbasic2/BackgroundQueueProcessingJob.st,v 1.4 2011-08-02 17:48:55 cg Exp $'
+ ^ '$Header: /cvs/stx/stx/libbasic2/BackgroundQueueProcessingJob.st,v 1.5 2011-08-03 14:43:30 cg Exp $'
!
version_SVN