Skip to main content

Python Multithreading Example




import requests
import threading

count = 0
fcount = 0
nreach = 0

def myWorker():
    global nreach
    try:
         r  = requests.get("http://10.184.36.38:8088/")
         print "Thread Name ", threading.current_thread().name
         if r.status_code == 200:
             global count
             count = count +1
         else:
             global fcount
             fcount = fcount + 1
         print "%d   %d" %(count, fcount)
     
    except requests.ConnectionError:
        print "%s No Connection " %(threading.current_thread().name)
        nreach=nreach+1
        print "Not reaching "+str(nreach)
    except:
        print 'Encoding Error'
        nreach=nreach+1
        print "Not reaching "+str(nreach)


threads = []
if __name__ == "__main__":

    for i in range(100):
        t = threading.Thread(name= "Thread-"+str(i), target=myWorker)
        threads.append(t)
        t.start()
#        print 'Thread {} started'.format(str(i))

#    for thread in threads:
#        print "Thread Joined "+thread.name
#        thread.join()

#    print 'Program Terminated !!!! '


Comments