import threading
import random
class CreateJob (threading.Thread):
def __init__(self, threadID):
threading.Thread.__init__(self)
self.threadID = threadID
#run is an default method for threading class
def run(self):
Write(self.threadID)
ReWrite(self.threadID)
def Write(threadID):
print "Writing Data to File"
dd = open('Writer_{}.txt'.format(threadID),'w')
print >>dd,"Thread_{}_{}".format(threadID,random.getrandbits(64))
dd.close()
def ReWrite(threadID):
print "Reading Data from File"
p = open("Writer_{}.txt".format(threadID),'r').read()
ff = open("Reader_{}.txt".format(threadID),'w')
print >>ff,"{}_{}".format("Fetcher : ", str(p))
for x in xrange(1,3):
thread = CreateJob(random.getrandbits(64))
thread.start()
#Output
# Writing Data to File
# Writing Data to File
# Reading Data from File
# Reading Data from File