• Home
  • Categories
  • WIKI
  • LANGUAGE: en
    • gtk 线程笔记
    社区开发 2212 views · 1 replies ·
    Tofloor
    poster avatar
    z85525006
    deepin
    2012-09-10 07:46
    Author
    我作的笔记,下次好自己翻翻... .. 不要喷我.
    因为本人要研究在线视频,要用到线程池等一些东西,所以就做点笔记什么的,大家不要以为是什么东西.
    3. #coding:utf-8
    5. import gtk
    6. import threading
    9. gtk.gdk.threads_init()
    11. class Test(object):
    12.     def __init__(self):
    13.         self.win = gtk.Window(gtk.WINDOW_TOPLEVEL)        
    14.         
    15.         self.btn = gtk.Button("按钮一")               
    16.         
    17.         self.win.add(self.btn)
    18.         
    19.         self.btn.connect("clicked", self.test_btn_clicked)
    20.         self.win.connect("destroy", lambda w : gtk.main_quit())
    21.         
    22.         self.win.show_all()
    23.         
    24.     def test_btn_clicked(self, widget):        
    25.         
    26.         threading_id = threading.Thread(target=self.test_print)
    27.         threading_id.setDaemon(True)
    28.         threading_id.start()
    29.         
    30.     def test_print(self):
    31.         i = 0
    32.         while True:            
    33.             # gtk.gdk.threads_enter()
    34.             self.btn.set_label(str(i))
    35.             # gtk.gdk.threads_leave()
    36.             i += 1
    37. Test()        
    38. gtk.main()
    Copy the Code

    MFC界面线程详解: http://zhou24388.blog.163.com/bl ... 327201172992145405/
    http://www.cnblogs.com/yinh/archive/2005/05/25/162150.aspx
    2. #coding:utf-8
    4. import os
    5. import time
    6. import gtk
    7. import threading
    10. gtk.gdk.threads_init()
    12. class Test(object):
    13.     def __init__(self):
    14.         self.win = gtk.Window(gtk.WINDOW_TOPLEVEL)        
    15.         self.fixed = gtk.Fixed()
    16.         self.btn = gtk.Button("按钮一")               
    17.         self.btn2 = gtk.Button("按钮二")
    18.         self.btn3 = gtk.Button("按钮三")
    19.         self.btn.connect("clicked", self.test_button_clicked)
    20.         self.btn2.connect("clicked", self.test_button_clicked)
    21.         self.btn3.connect("clicked", self.test_button_clicked)
    22.         self.win.connect("destroy", lambda w : gtk.main_quit())
    23.         
    24.         self.fixed.put(self.btn, 20, 20)
    25.         self.fixed.put(self.btn2, 120, 20)
    26.         self.fixed.put(self.btn3, 500, 500)
    27.         self.win.add(self.fixed)
    28.         self.win.show_all()
    29.         
    30.     def test_button_clicked(self, widget):               
    31.         threading_id = threading.Thread(target=self.test_move_button, args=(widget,))
    32.         threading_id.setDaemon(True)
    33.         threading_id.start()        
    34.         
    35.     def test_move_button(self, button):
    36.         x = 0
    37.         y = 0
    38.         while True:
    39.             x += 5
    40.             if x > 200:
    41.                 x = 0
    42.                 y += 15                    
    43.             gtk.gdk.threads_enter()        
    44.             self.fixed.move(button, x, y)
    45.             gtk.gdk.threads_leave()
    46.             
    47.             time.sleep(0.1)
    48. Test()        
    49. gtk.main()
    Copy the Code

    线程中 队列 生产者 与 消费者队列的例子. 这个例子对于编写 线程池非常有帮助.
    3. #coding:utf-8
    5. from Queue import Queue
    6. import threading
    7. import random
    8. import time
    10. class Producer(threading.Thread):
    11.     def __init__(self, threadname, queue):
    12.         threading.Thread.__init__(self, name = threadname)
    13.         self.sharedata = queue
    14.         
    15.     def run(self):   
    16.         for i in range(20):
    17.             print self.getName(), i, "将值放入队列中:"
    18.             self.sharedata.put(i)
    19.         time.sleep(random.randrange(10)/10.0)
    20.         print self.getName(), '完成!!'
    21.         
    22. class Consumer(threading.Thread):        
    23.     def __init__(self, threadname, queue):
    24.         threading.Thread.__init__(self, name = threadname)
    25.         self.sharedata = queue
    26.         
    27.     def run(self):   
    28.         for i in range(20):
    29.             print self.getName(), '从队列中获取值:', self.sharedata.get()
    30.         time.sleep(random.randrange(10)/10.0)   
    31.         print self.getName(), '完成!!'
    32.         
    33. def main():        
    34.     queue = Queue()
    35.     producer = Producer('producer', queue)
    36.     consumer = Consumer('consumer', queue)
    37.    
    38.     print '线程开始...........'
    39.     producer.start()
    40.     consumer.start()
    41.    
    42.     producer.join()
    43.     consumer.join()
    44.    
    45.     print "所有线程执行完毕"
    46.    
    47. if __name__ == "__main__":   
    48.     main()
    Copy the Code

    扫描目录的线程的暂停和继续.
    2. #coding:utf-8
    3. import threading
    4. import time
    5. import os
    7. '''
    8. 这个例子是利用了  迭代器 的特点去扫描目录, 将递归尽量的分解了.
    9. 暂停和继续是使用了 event.
    10. '''
    11. event = threading.Event()
    13. def walk(path):
    14.     event.wait() # 暂停线程
    15.     try:
    16.         if os.path.isdir(path):
    17.             for file in os.listdir(path):
    18.                 file_path = os.path.join(path, file)
    19.                 for sub_file in walk(file_path):
    20.                     yield sub_file
    21.         else:
    22.             yield path
    23.     except:
    24.         print "read file error!!"
    26. def func():
    27.     for file in walk("/"):
    28.         print file
    30. def test():
    31.     th2 = threading.Thread(target=func)
    32.     th2.setDaemon(True) # 和GTK的主线程一起退出
    33.     th2.start()
    36. if __name__ == '__main__':
    37.     def btn_clicked(widget):
    38.         test()
    39.         print "start..."
    41.     def stop_btn_clicked(widget):
    42.         event.clear() # 暂停线程
    44.     def start_btn_clicked(widget):
    45.         event.set() # 开始线程
    47.     import gtk
    48.     # 初始化线程.
    49.     gtk.gdk.threads_init()
    50.    
    51.     win = gtk.Window(gtk.WINDOW_TOPLEVEL)     
    52.     btn = gtk.Button("初始化线程")   
    53.     stop_btn = gtk.Button("暂停扫描目录")   
    54.     start_btn = gtk.Button("开始扫描目录")   
    55.     hbox = gtk.HBox()   
    56.    
    57.     win.connect("destroy", lambda w : gtk.main_quit())
    58.     btn.connect("clicked", btn_clicked)
    59.     stop_btn.connect("clicked", stop_btn_clicked)
    60.     start_btn.connect("clicked", start_btn_clicked)
    61.    
    62.     hbox.pack_start(btn)
    63.     hbox.pack_start(start_btn)
    64.     hbox.pack_start(stop_btn)
    65.    
    66.     win.add(hbox)
    67.     win.show_all()
    68.    
    69.     gtk.gdk.threads_enter()
    70.     gtk.main()
    71.     gtk.gdk.threads_leave()
    Copy the Code
    Reply Favorite View the author
    All Replies
    ldmpscript
    deepin
    2012-12-24 02:48
    #1
    1. ##########################################
    2. ## 线程扫描目录.  
    3. ## scan_dir = ScanDir('/home')
    4. ## scan_dir.connect("scan-file-event",self.scan..  ..
    5. ## def scan_file_event(scan_dir, file_name):...        
    6. class ScanDir(gobject.GObject):               
    7.     __gsignals__ = {
    8.         "scan-file-event" : (gobject.SIGNAL_RUN_LAST, gobject.TYPE_NONE,
    9.                              (gobject.TYPE_STRING,)),
    10.         "scan-end-event" : (gobject.SIGNAL_RUN_LAST, gobject.TYPE_NONE,
    11.                              ()),        
    12.         }            
    13.     def __init__(self, path):
    14.         gobject.GObject.__init__(self)
    15.         self.event = threading.Event()
    16.         self.path = path
    17.         self.__run()
    18.         
    19.     def pause(self): # 暂停线程
    20.         self.event.clear()
    21.         
    22.     def start(self): # 开启线程
    23.         self.event.set()
    24.         
    25.     def __wait(self):  
    26.         self.event.wait()
    27.         
    28.     def enter(self):   
    29.         gtk.gdk.threads_enter()
    30.         
    31.     def leave(self):   
    32.         gtk.gdk.threads_leave()        
    33.         
    34.     def __scan(self, path):
    35.         self.__wait()
    36.         try:
    37.             if os.path.isdir(path):
    38.                 for file_ in os.listdir(path):
    39.                     file_path = os.path.join(path, file_)
    40.                     for sub_file in self.__scan(file_path):
    41.                         yield sub_file
    42.             else:   
    43.                 yield path
    44.         except:
    45.             print "read file error!!"
    46.                     
    47.     def __run(self):
    48.         scan_th = threading.Thread(target=self.__run_func)
    49.         scan_th.setDaemon(True)
    50.         scan_th.start()
    51.         
    52.     def __run_func(self):   
    53.         for file_ in self.__scan(self.path):
    54.             self.emit("scan-file-event", file_)
    55.         self.emit("scan-end-event")   
    56.         
    57. if __name__ == "__main__":            
    58.     gtk.gdk.threads_init()   
    59.     def scan_file_event(scan_dir, file_name):
    60.         gtk.gdk.threads_enter()
    61.         label.set_label(file_name)
    62.         gtk.gdk.threads_leave()
    63.         
    64.     def scan_end_event(scan_dir):   
    65.         gtk.gdk.threads_enter()
    66.         label.set_label("%s扫描完毕"%(scan_dir.path))
    67.         gtk.gdk.threads_leave()        
    68.         
    69.     def start_btn_clicked(widget):   
    70.         scan_dir.start()
    71.         
    72.     def pause_btn_clicked(widget):   
    73.         scan_dir.pause()
    74.         
    75.     scan_dir = ScanDir("/")
    76.     scan_dir.connect("scan-file-event", scan_file_event)               
    77.     scan_dir.connect("scan-end-event", scan_end_event)
    78.     win = gtk.Window(gtk.WINDOW_TOPLEVEL)
    79.     win.set_title("线程测试!!")
    80.     vbox = gtk.VBox()
    81.     hbox = gtk.HBox()
    82.     start_btn=gtk.Button("开始")
    83.     pause_btn=gtk.Button("暂停")   
    84.     hbox.pack_start(start_btn, False, False)
    85.     hbox.pack_start(pause_btn, False, False)
    86.     label = gtk.Label("...")   
    87.     vbox.pack_start(hbox, False, False)
    88.     vbox.pack_start(label, False, False)
    89.     win.add(vbox)   
    90.     win.connect("destroy", lambda w : gtk.main_quit())   
    91.     start_btn.connect("clicked", start_btn_clicked)
    92.     pause_btn.connect("clicked", pause_btn_clicked)
    93.     win.show_all()
    94.    
    95.     gtk.gdk.threads_enter()
    96.     gtk.main()
    97.     gtk.gdk.threads_leave()
    Copy the Code
    Reply View the author