This file is indexed.

/usr/share/gnu-smalltalk/kernel/SharedQueue.st is in gnu-smalltalk-common 3.2.4-2.

This file is owned by root:root, with mode 0o644.

The actual contents of the file can be viewed below.

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
"======================================================================
|
|   SharedQueue Method Definitions
|
|
 ======================================================================"

"======================================================================
|
| Copyright 1988,92,94,95,99,2000,2001,2002
| Free Software Foundation, Inc.
| Written by Steve Byrne.
|
| This file is part of the GNU Smalltalk class library.
|
| The GNU Smalltalk class library is free software; you can redistribute it
| and/or modify it under the terms of the GNU Lesser General Public License
| as published by the Free Software Foundation; either version 2.1, or (at
| your option) any later version.
| 
| The GNU Smalltalk class library is distributed in the hope that it will be
| useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
| MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Lesser
| General Public License for more details.
| 
| You should have received a copy of the GNU Lesser General Public License
| along with the GNU Smalltalk class library; see the file COPYING.LIB.
| If not, write to the Free Software Foundation, 59 Temple Place - Suite
| 330, Boston, MA 02110-1301, USA.  
|
 ======================================================================"



Object subclass: SharedQueue [
    | queueSem valueReady queue |
    
    <category: 'Language-Processes'>
    <comment: 'My instances provide a guaranteed safe mechanism to allow for communication
between processes.  All access to the underlying data structures is
controlled with critical sections so that things proceed smoothly.'>

    SharedQueue class >> new [
	"Create a new instance of the receiver"

	<category: 'instance creation'>
	^self basicNew init: (OrderedCollection new: 10)
    ]

    SharedQueue class >> sortBlock: sortBlock [
	"Create a new instance of the receiver which implements a
	 priority queue with the given sort block"

	<category: 'instance creation'>
	^self basicNew init: (SortedCollection sortBlock: sortBlock)
    ]

    isEmpty [
	"Answer whether there is an object on the queue"

	<category: 'accessing'>
	^queue isEmpty
    ]

    next [
	"Wait for an object to be on the queue, then remove it and answer it"

	<category: 'accessing'>
	| result |
	valueReady wait.
	queueSem critical: [result := queue removeFirst].
	^result
    ]

    nextPut: value [
	"Put value on the queue and answer it"

	<category: 'accessing'>
	queueSem critical: [queue add: value].
	valueReady signal.
	^value
    ]

    peek [
	"Wait for an object to be on the queue if necessary, then answer the
	 same object that #next would answer without removing it."

	<category: 'accessing'>
	| result |
	valueReady wait.
	queueSem critical: [result := queue first].
	valueReady signal.
	^result
    ]

    init: aCollection [
	<category: 'private'>
	queue := aCollection.
	valueReady := Semaphore new.
	queueSem := Semaphore forMutualExclusion
    ]
]