Changeset 18594 for lang/python

Timestamp:

09/01/08 23:57:49 (4 months ago)

Author:

showyou

Message:

crochet マルチスレッド化。ただし排他処理がまだなのでよくセグフォ

Files:

• lang/python/crochet/chat_allsrc.py (modified) (10 diffs)

lang/python/crochet/chat_allsrc.py

@@ -13 +13 @@
 import Image
 
-import threading
-
+import thread
 """
 画像取得用スレッド
 """
-class ImageGetThread(threading.Thread):
+class ImageGetFrame(wx.Frame):
         def __init__(self,url,callbackFunc,result):
-                threading.Thread.__init__(self)
                 self.url = url 
                 self.func = callbackFunc 
                 self.result = result
+        def start(self):
+                thread.start_new_thread(self.run(), ())
+
         def run(self):
                 import urllib,time
@@ -30 +31 @@
                 #time.sleep(1)
                 self.func(imagePath,self.result)
+                
+
 """
 twitterにhttpRequestを投げるスレッド
 """
-class TwDMHttpThread(threading.Thread):
+class TwDMHttpFrame(wx.Frame):
         def __init__(self,tw,func):
-                threading.Thread.__init__(self)
                 self.tw = tw
                 self.func = func
+        def start(self):
+                thread.start_new_thread(self.run, ())
         def run(self):
                 #ここに通信処理を書く
@@ -45 +49 @@
 twitterにhttpRequestを投げるスレッド
 """
-class TwReplyHttpThread(threading.Thread):
+class TwReplyHttpFrame(wx.Frame):
         def __init__(self,tw,func):
-                threading.Thread.__init__(self)
                 self.tw = tw
                 self.func = func
+        def start(self):
+
+                thread.start_new_thread(self.run, ())
+        
         def run(self):
                 #ここに通信処理を書く
@@ -57 +64 @@
 twitterにhttpRequestを投げるスレッド
 """
-class TwHttpThread(threading.Thread):
+class TwHttpFrame(wx.Frame):
         def __init__(self,tw,func):
-                threading.Thread.__init__(self)
                 self.tw = tw
                 self.func = func
+        def start(self):
+                thread.start_new_thread(self.run, ())
+
         def run(self):
                 #ここに通信処理を書く
@@ -89 +98 @@
         
         def Reflesh(self):
-                t = TwDMHttpThread(self.owner.tw,self.RefleshList)
-                t.run()
+                t = TwDMHttpFrame(self.owner.tw,self.RefleshList)
+                t.start()
 """
 最近のfriendsの発言一覧を表示するページ
@@ -193 +202 @@
 
         def Reflesh(self):
-                t = TwHttpThread(self.owner.tw,self.RefleshList)
-                t.run()
+                t = TwHttpFrame(self.owner.tw,self.RefleshList)
+                t.start()
         
         def RefleshList(self,a):
@@ -262 +271 @@
         
         def Reflesh(self):
-                t = TwReplyHttpThread(self.owner.tw,self.RefleshList)
-                t.run()
+                t = TwReplyHttpFrame(self.owner.tw,self.RefleshList)
+                t.start()
 
         
@@ -308 +317 @@
                 
         def __init__(self, parent=None):
+                #from pit import Pit
+                #twUserdata = Pit.get('twitter.com',{'require' : {'user':'','pass':''}})
                 twUserdata = self.loadUserData(".chat/twdata")
                 wx.Frame.__init__(self,None, -1, "crochet")
@@ -391 +402 @@
         
         def OnUpdate(self, event):
+                self.SetStatusBar(u"新着取得中...")
                 self.RefleshTw()
-                self.SetNowTime2StatusBar()
         
         def OnReplyUpdate(self, event):
+        
+                self.SetStatusBar(u"Reply取得中")
                 self.replyPage.Reflesh()
-                #self.SetNowTime2StatusBar()
 
         def OnDMUpdate(self, event):
+                
+                self.SetStatusBar(u"DM取得中...")
                 self.directPage.Reflesh()
-                #self.SetNowTime2StatusBar()
-
+
+        def SetStatusBar(self,str):
+                
+                sb = wx.GetApp().GetTopWindow().GetStatusBar()
+                sb.SetStatusText(str)
         def SetNowTime2StatusBar(self):
                 #現在時刻を表示
@@ -458 +475 @@
                 #print "urlName:"+urlName
                 #thread化したいですね
-                t = ImageGetThread(urlName,self.WebImageCallback,result)
-                t.run()
+                t = ImageGetFrame(urlName,self.WebImageCallback,result)
+                t.start()
 
         def WebImageCallback(self,imageData,result):