Das deutsche Python-Forum

Code: Alles auswählen

import threading
import time

# [ID, Programm, Paramter]
db = [[1, 1, 50], [2, 2, 20]]


class TestThread1 ( threading.Thread ):

    def __init__ ( self, tsleep ):
        threading.Thread.__init__( self )
        self.tsleep = tsleep

    def run ( self ):
        i = 1
        while 1:
            time.sleep(self.tsleep)
            print "Thread Programm 1: i = %s" % (i)
            i = i + 1


class TestThread2 ( threading.Thread ):

    def __init__ ( self, tsleep ):
        threading.Thread.__init__( self )
        self.tsleep = tsleep

    def run ( self ):
        i = 1
        while 1:
            time.sleep(self.tsleep)
            print "Thread Programm 2: i = %s" % (i)
            i = i + 1
            

Threads = []

for x in db:
    if x[1] == 1:
        Threads.append ( TestThread1(x[2]) )
    elif x[1] == 2:
        Threads.append ( TestThread2(x[2]) )


# Threads starten
for t in Threads:
    t.start()

Code: Alles auswählen

import threading

class Worker(threading.Thread):
    def __init__(self):
        super(Worker, self).__init__()
        self.timer    = None
        self.runflag  = True
        self.lock     = threading.Lock()

    def run(self):
        self.lock.acquire()
        if self.runflag:

            #
            # hier können die "wichtigen" Aufgaben erledigt werden ;-)
            #

            # nach 10 Sekunden wird self.run gestartet
            self.timer = threading.Timer(10, self.run)
            self.timer.start()
        self.lock.release()

    def stop(self):
        self.lock.acquire()
        self.runflag = False
        if self.timer:
            self.timer.cancel()
        self.lock.release()

Code: Alles auswählen

Traceback (most recent call last):
  File "C:\Ordner\Test\GUI.py", line 991, in buttonClick
    self.omodem.start()
  File "C:\python25\lib\threading.py", line 436, in start
    raise RuntimeError("thread already started")
RuntimeError: thread already started