modbus tk sample

gistfile1.py

#!/usr/bin/env python
# -*- encoding: utf-8 -*-

import threading
import time
from random import random

lock = threading.Lock()

def thread_safe(func):
    def wrapper(*args, **kwargs):
        with lock:
            func(*args, **kwargs)
    return wrapper

@thread_safe
def execute(tid):
    working_time = random()
    time.sleep(working_time)
    print 'Th[%s]: Working %s sec' % (tid, working_time)

for i in xrange(60):
    threading.Thread(target=execute, args=(i,)).start()

print 'exit before ends...'