如何在Kivy-python中使用带有多线程的Clock对象来更新进度栏? [英] How to update progressbar using Clock Object with Multithreading in kivy-python?

问题描述

我正在使用linux创建奇特的应用程序.我在使用python-kivy中的多线程时钟对象更新进度条gui时遇到问题.我正在使用两个文件.kv& .py文件运行该应用.

I am making an app in kivy for that i am using linux. i am getting a problem to update the progress bar gui using clock object with multithreading in python-kivy. i am using both files .kv & .py file run the app.

我的main.py文件:

my main.py file:

from kivy.app import App
from kivy.uix.label import Label
from kivy.uix.boxlayout import BoxLayout
from kivy.uix.progressbar import ProgressBar
from kivy.uix.button import Button
from kivy.uix.popup import Popup
from kivy.clock import Clock
import sys, threading, os, time
from socket import *

class Out_Come(BoxLayout):


    def Input_manager(self, *args):
        try:
            t = self.ids.nd.text
            I=socket.gethostbyname(t)
            st = self.ids.ti.text
            et = self.ids.it.text
            st1=int(st)
            et1=int(et)
            while st1<=et1:
                work=my_function(I,st1)
                work.start()
                Clock.schedule_once(lambda dt: work.run, 1)
                st1=st1+1
                self.ids.pb.value=self.ids.pb.value+1
    except:
        "Error"
class my_function(threading.Thread):
    def __init__(self,n, d):
        threading.Thread.__init__(self)
        self.n = n
            self.d = d
    def run(self):
        try:
            get = socket(AF_INET, SOCK_STREAM)
            get.settimeout(4)
            get.connect((gethostbyname(self.n), int(self.d)))
            print"done", self.d
            get.close()
        except:
            print"not done", self.d

class Example_app(App):

    def build(self):
        return Out_Come()


if __name__ == '__main__':
    Example_app().run()

我的.kv文件:

<Out_Come>:
    GridLayout:
        orientation:'vertical'
        rows:2
        cols:2
        padding:10
        spacing:10
        Label:
            text:"[b]Enter value:[b]"
            markup:True
            size_hint:.3,.3
        TextInput:
            id:nd
            text: ""
            height:40 
            multiline:False

        GridLayout:
            orientation: 'vertical'
            rows:2
            cols:4
            padding:10
            spacing:10
            Label:
                text:"[b]First:[b]"
                height:40
                size_hint:.25,.25
                markup:True
            TextInput:
                id:ti
                text:""
                height: 40
                size_hint:.25,.25
                multiline:False
            Label:
                text:"[b]last[b]"
                height:40
                size_hint:.25,.25
                markup:True
            TextInput:
                id:it
                text:""
                height:40
                size_hint:.25,.25
                multiline:False

        GridLayout:
            orientation: 'vertical'
            rows:1
            cols:2
            padding:10
            spacing:10
            Button:
                id:get
                text:'Start'
                size_hint:.3,.3
                on_press: root.Input_manager()
        ProgressBar:
            id:pb
            max:100
            value:0

进度栏是否正在完美更新?我想完美地实时更新它.请告诉我执行此代码的更好方法.预先感谢.

Is the progress bar perfectly updating? i want upate it prefectly in live time. Please tell me the better way to execute this code. Thanks in advance.

推荐答案

您的代码有一些问题:

UI线程中存在一个循环(这将停止UI更新)

You have a loop in your UI thread (which will stop the UI updating)

        while st1<=et1:
            work=my_function(I,st1)
            work.start()
            Clock.schedule_once(lambda dt: work.run, 1)
            st1=st1+1
            self.ids.pb.value=self.ids.pb.value+1

您需要像这样将循环传递到您的线程中:

You need to pass the loop into your thread like this:

   ...
   def Input_manager(self, *args):
        ...
        st1=int(st)
        et1=int(et)

        work=my_function(I,st1, est1,
                         #sending a thread safe update progress bar function
                         lambda : Clock.schedule_once(self.update_bar))
        work.start()

   def update_bar(self, dt=None):
      self.ids.pb.value=self.ids.pb.value+1

class my_function(threading.Thread):
    def __init__(self,n, st, et, update_bar):
        threading.Thread.__init__(self)
        self.n = n
        self.st = st
        self.et = et
        self.update_bar = update_bar
    def run(self):
        for din range(self.st1, self.et1+1):
            try:
                get = socket(AF_INET, SOCK_STREAM)
                get.settimeout(4)
                get.connect((gethostbyname(self.n), int(d)))
                print"done", d
                get.close()
            except:
                print"not done", d
            finally:
                self.update_bar() #this is our callback to update the bar!

还有更多要解决的问题(样式方面)，但这不在上下文之内

There are more fixes to be done (style wise) but that is outside the context

注意-尚未进行任何测试...

Note - this was not tested by any means...

这篇关于如何在Kivy-python中使用带有多线程的Clock对象来更新进度栏?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！