From e3e2339cf2156a12b61b91f56c9ea596df57198e Mon Sep 17 00:00:00 2001
From: necoro <>
Date: Tue, 7 Aug 2007 06:09:41 +0000
Subject: new threading model in gui_helper

---
 portato/waiting_queue.py | 61 ++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 61 insertions(+)
 create mode 100644 portato/waiting_queue.py

(limited to 'portato/waiting_queue.py')

diff --git a/portato/waiting_queue.py b/portato/waiting_queue.py
new file mode 100644
index 0000000..409843c
--- /dev/null
+++ b/portato/waiting_queue.py
@@ -0,0 +1,61 @@
+# -*- coding: utf-8 -*-
+#
+# File: portato/waiting_queue.py
+# This file is part of the Portato-Project, a graphical portage-frontend.
+#
+# Copyright (C) 2007 René 'Necoro' Neumann
+# This is free software.  You may redistribute copies of it under the terms of
+# the GNU General Public License version 2.
+# There is NO WARRANTY, to the extent permitted by law.
+#
+# Written by René 'Necoro' Neumann <necoro@necoro.net>
+
+from threading import Thread, Event
+from Queue import Queue
+
+class WaitingQueue (Queue):
+
+	def __init__ (self, setTrue = True, threadClass = Thread):
+		if not issubclass(threadClass, Thread):
+			raise ValueError, "Only subclasses of threading.Thread are allowed."
+		
+		Queue.__init__(self)
+		self.event = Event()
+		self.counter = 0
+		self.threadClass = threadClass
+
+		if setTrue:
+			self.event.set() # true at the beginning
+
+		waitingThread = self.threadClass(name = "Waiting-Queue-Thread", target = self.runThread)
+		waitingThread.setDaemon(True)
+		waitingThread.start()
+
+	def put (self, method, *args, **kwargs):
+		self.counter += 1;
+		
+		if "caller" in kwargs:
+			name = "Waiting Thread #%d (called by:%s)" % (self.counter, kwargs["caller"])
+			del kwargs["caller"]
+		else:
+			name = "Waiting Thread #%d" % self.counter
+
+		t = self.threadClass(name = name, target = method, args = args, kwargs = kwargs)
+		t.setDaemon(True)
+		Queue.put(self, t, False)
+
+	def runThread (self):
+		while True:
+			self.event.wait()
+			t = self.get(True)
+			self.event.clear()
+			t.run()
+
+	def next (self):
+		self.event.set()
+
+	def clear (self):
+		self.mutex.acquire()
+		self.queue.clear()
+		self.mutex.release()
+		self.event.set()
-- 
cgit v1.2.3