PureBoard

Code: Alles auswählen

If \Queue(x)\Active
 .. hau raus...
 \Queue(x)\Active = #False
EndIf

Code: Alles auswählen

    For i=0 To 512
      If \Queue(i)\Active = #False
        \Queue(i)\Data     = *Data
             ...hau rein..
        \Queue(i)\Active   = #True
        Break
      EndIf
    Next

Code: Alles auswählen

EnableExplicit

DeclareModule FifoBuffer
	Declare.i create(size.i)
	Declare free(*fifo)
	Declare pushBack(*fifo, *data)
	Declare.i getNext(*fifo)
EndDeclareModule

Module FifoBuffer

	Structure FifoElement
		*p[0]
	EndStructure

	Structure FifoBuffer
		size.i
		iRead.i
		iWrite.i
		writeSemaphore.i
		readSemaphore.i
		writeLock.i
		readLock.i
		*buffer.FifoElement
	EndStructure
	
	Procedure.i create(size.i)
		Protected *fifo.FifoBuffer = AllocateMemory(SizeOf(FifoBuffer))
		
		If (size > 2147483647)
			ProcedureReturn #False
		EndIf
		
		If (Not *fifo)
			ProcedureReturn #False
		EndIf
		
		With *fifo
			\size					= size
			\iWrite				= 0
			\iRead				= 0
			\readSemaphore		= CreateSemaphore(0)
			\writeSemaphore	= CreateSemaphore(size)
			\readLock			= CreateMutex()
			\writeLock			= CreateMutex()
			\buffer				= AllocateMemory(size * SizeOf(Integer))
			If (Not \buffer)
				FreeMemory(*fifo)
				ProcedureReturn #False
			EndIf
		EndWith
		
		ProcedureReturn *fifo
	EndProcedure
	
	Procedure free(*fifo.FifoBuffer)
		With *fifo
			FreeSemaphore(\readSemaphore)
			FreeSemaphore(\writeSemaphore)
			FreeMutex(\readLock)
			FreeMutex(\writeLock)
			FreeMemory(\buffer)
		EndWith
		FreeMemory(*fifo)
	EndProcedure
	
	Procedure pushBack(*fifo.FifoBuffer, *data)
		With *fifo
			LockMutex(\writeLock)
				WaitSemaphore(\writeSemaphore)
				Debug "Push " + Str(*data) + " back (iWrite=" + Str(\iWrite) + ")"
				\buffer\p[\iWrite] = *data
				\iWrite = (\iWrite + 1) % \size
				SignalSemaphore(\readSemaphore)
			UnlockMutex(\writeLock)
		EndWith
	EndProcedure
	
	Procedure.i getNext(*fifo.FifoBuffer)
		Protected *data
		With *fifo
			LockMutex(\readLock)
				WaitSemaphore(\readSemaphore)
				*data = \buffer\p[\iRead]
				\iRead = (\iRead + 1) % \size
				Debug "Got " + Str(*data) + "(iRead=" + Str(\iRead) + ")"
				SignalSemaphore(\writeSemaphore)
			UnlockMutex(\readLock)
		EndWith
		
		ProcedureReturn *data
	EndProcedure
EndModule

; E X A M P L E
Procedure WriterThread(*fifo)
	Protected i.i
	For i = 1 To 22
		FifoBuffer::pushBack(*fifo, i)
	Next
	FifoBuffer::pushBack(*fifo, 0)
EndProcedure

Procedure ReaderThread(*fifo)
	Protected i.i
	Repeat
		i = FifoBuffer::getNext(*fifo)
	Until i = 0
EndProcedure

Define *fifo = FifoBuffer::create(10)
Define *t1, *t2

*t2 = CreateThread(@WriterThread(), *fifo)
;Erstmal den Puffer vollschreiben lassen und 10 ms warten
Delay(10)
*t1 = CreateThread(@ReaderThread(), *fifo)

WaitThread(*t1)
WaitThread(*t2)

FifoBuffer::free(*fifo)