AGB  ·  Datenschutz  ·  Impressum  







Anmelden
Nützliche Links
Registrieren
Thema durchsuchen
Ansicht
Themen-Optionen

BlockingQueue in Delphi 7

Ein Thema von Nic2012 · begonnen am 4. Mai 2012 · letzter Beitrag vom 9. Mai 2012
Antwort Antwort
Nic2012

Registriert seit: 2. Mai 2012
62 Beiträge
 
#1

BlockingQueue in Delphi 7

  Alt 4. Mai 2012, 13:31
Ich habe eine C#-Klasse in Delphi zu migrieren:
Wie würde man sowas in D7 lösen:
Code:
   public class BlockingQueue
   {
      private bool closing;
      private readonly Queue<byte[]> queue = new Queue<byte[]>();
      public int Count
      {
         get
         {
            lock(queue)
            {
               return queue.Count;
            }
         }
      }
      public BlockingQueue()
      {
         lock(queue)
         {
            closing = false;
            Monitor.PulseAll(queue);
         }
      }
      public bool Enqueue(byte[] item)
      {
         lock (queue)
         {
            if(closing || null == item)
            {
               return false;
            }
            queue.Enqueue(item);

            if(queue.Count == 1)
            {
               // wake up any blocked dequeue
               Monitor.PulseAll(queue);
            }
            return true;
         }
      }
      public void Close()
      {
         lock(queue)
         {
            if(!closing)
            {
               closing = true;
               queue.Clear();
               Monitor.PulseAll(queue);
            }
         }
      }
      public bool TryDequeue(out byte[] value, int timeout = Timeout.Infinite)
      {
         lock(queue)
         {
            while(queue.Count == 0)
            {
               if(closing || 
                  (timeout < Timeout.Infinite) || 
                  !Monitor.Wait(queue, timeout))
               {
                  value = null;
                  return false;
               }
            }
            value = (byte[])queue.Dequeue();
            return true;
         }
      }
      public void Clear()
      {
         lock(queue)
         {
            queue.Clear();
            Monitor.Pulse(queue);
         }
      }
   }
  Mit Zitat antworten Zitat
Benutzerbild von himitsu
himitsu

Registriert seit: 11. Okt 2003
Ort: Elbflorenz
43.142 Beiträge
 
Delphi 12 Athens
 
#2

AW: BlockingQueue in Delphi 7

  Alt 4. Mai 2012, 13:51
Du nimmst eine Queue-Klasse (weiß nicht ab wann es TQueue im Delphi gibt), baust dort eine CriticalSection ein (TCriticalSection oder direkt über die WinAPI), sicherst alle Zugriffsmethoden damit ab und fertig.

Bezüglich der CS gibt es ausreichend Beispiele zu finden
und eine "threadsichere Queue/Stack/List" gibt es hier auch zu finden (ist ja alles das Gleiche).
Garbage Collector ... Delphianer erzeugen keinen Müll, also brauchen sie auch keinen Müllsucher.
my Delphi wish list : BugReports/FeatureRequests

Geändert von himitsu ( 4. Mai 2012 um 13:54 Uhr)
  Mit Zitat antworten Zitat
Nic2012

Registriert seit: 2. Mai 2012
62 Beiträge
 
#3

AW: BlockingQueue in Delphi 7

  Alt 9. Mai 2012, 09:54
Habe es mit TQueue und TCriticalSection als Absicherung in D7 fast umgesetzt. Nur welche Alternative habe ich in D7 für die Monitor-Klasse, die es erst seit D2009 gibt ?
Bzw. die erste Hürde ist die Wait-Methode von TMonitor. Kann man ev. dafür WaitForSingleObject verwenden ?

Geändert von Nic2012 ( 9. Mai 2012 um 09:56 Uhr)
  Mit Zitat antworten Zitat
Antwort Antwort


Forumregeln

Es ist dir nicht erlaubt, neue Themen zu verfassen.
Es ist dir nicht erlaubt, auf Beiträge zu antworten.
Es ist dir nicht erlaubt, Anhänge hochzuladen.
Es ist dir nicht erlaubt, deine Beiträge zu bearbeiten.

BB-Code ist an.
Smileys sind an.
[IMG] Code ist an.
HTML-Code ist aus.
Trackbacks are an
Pingbacks are an
Refbacks are aus

Gehe zu:

Impressum · AGB · Datenschutz · Nach oben
Alle Zeitangaben in WEZ +1. Es ist jetzt 15:57 Uhr.
Powered by vBulletin® Copyright ©2000 - 2024, Jelsoft Enterprises Ltd.
LinkBacks Enabled by vBSEO © 2011, Crawlability, Inc.
Delphi-PRAXiS (c) 2002 - 2023 by Daniel R. Wolf, 2024 by Thomas Breitkreuz