home *** CD-ROM | disk | FTP | other *** search
/ The CDPD Public Domain Collection for CDTV 3 / CDPDIII.bin / pd / programming / gnusmalltalk / sharedqueue.st < prev    next >
Text File  |  1992-02-15  |  2KB  |  84 lines
  1. "======================================================================
  2. |
  3. |   SharedQueue Method Definitions
  4. |
  5.  ======================================================================"
  6.  
  7.  
  8. "======================================================================
  9. |
  10. | Copyright (C) 1990, 1991, 1992 Free Software Foundation, Inc.
  11. | Written by Steve Byrne.
  12. |
  13. | This file is part of GNU Smalltalk.
  14. |
  15. | GNU Smalltalk is free software; you can redistribute it and/or modify it
  16. | under the terms of the GNU General Public License as published by the Free
  17. | Software Foundation; either version 1, or (at your option) any later version.
  18. | 
  19. | GNU Smalltalk is distributed in the hope that it will be useful, but WITHOUT
  20. | ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
  21. | FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
  22. | details.
  23. | 
  24. | You should have received a copy of the GNU General Public License along with
  25. | GNU Smalltalk; see the file COPYING.  If not, write to the Free Software
  26. | Foundation, 675 Mass Ave, Cambridge, MA 02139, USA.  
  27. |
  28.  ======================================================================"
  29.  
  30.  
  31. "
  32. |     Change Log
  33. | ============================================================================
  34. | Author       Date       Change 
  35. | sbyrne     25 Apr 89      created.
  36. |
  37. "
  38.  
  39. Object subclass: #SharedQueue
  40.        instanceVariableNames: 'queueSem valueReady queue'
  41.        classVariableNames: ''
  42.        poolDictionaries: ''
  43.        category: nil
  44. !
  45.  
  46. SharedQueue comment: 
  47. 'My instances provide a guaranteed safe mechanism to allow for communication
  48. between processes.  All access to the underlying data structures is
  49. controlled with critical sections so that things proceed smoothly.' !
  50.  
  51.  
  52. !SharedQueue class methodsFor: 'instance creation'!
  53.  
  54. new
  55.     ^super new init
  56. !!
  57.  
  58.  
  59.  
  60. !SharedQueue methodsFor: 'accessing'!
  61.  
  62. next
  63.     | result |
  64.     valueReady wait.
  65.     queueSem critical: [ result _ queue removeFirst ].
  66.     ^result
  67. !
  68.  
  69. nextPut: value
  70.     queueSem critical: [ queue addLast: value ].
  71.     valueReady signal.
  72.     ^value
  73. !!
  74.  
  75.  
  76.  
  77. !SharedQueue methodsFor: 'private'!
  78.  
  79. init
  80.     queue _ OrderedCollection new: 10.
  81.     valueReady _ Semaphore new.
  82.     queueSem _ Semaphore forMutualExclusion
  83. !!
  84.