import threading
import time

class Worker (threading.Thread):
    def __init__(self):
        print("Init threading")
        super().__init__()

    def run(self) -> None:
        time.sleep(10)
        print("This is done by thread... ")
        

if __name__ == "__main__":

    print("Starting... ")

    worker = Worker()
    worker.start()

    while worker.is_alive():
        print("worker living")
        time.sleep(0.5)

run -pyf "C:\path\to\your\test.py";

# ... unchanged ...
    
#must not do print or anything related to Origin inside the thread function
def thread_task(lock, name):
    for _ in range(5):
        sleep(5)                                # Change: Wait for 5 seconds
        now = datetime.now()
        tt = now.strftime("%H:%M:%S.%f")[:-3]
        lock.acquire()
        write(tt, name)
        lock.release()

# ... unchanged ...

t1 = threading.Thread(target=thread_task, args=(lock,'a'))
t2 = threading.Thread(target=thread_task, args=(lock,'b'))
t1.start()
t2.start()
print("Waiting...")                             # Simple output (as soon as threads start)
t1.join()
t2.join()
print("Waiting done...")                        # Simple output (as soon as both threads finished)

# ... unchanged ...

quote:

---

Originally posted by cpyang

I think the problem is with the print command, as Origin channel that to display in Origin's window, which is not thread safe.

Can you avoid print and maybe write to a file instead?

CP

---

import threading
from datetime import datetime
from time import sleep
import originpro as op
import pathlib

filepath = pathlib.Path(pathlib.Path.home(), "Desktop/main.txt")
main_file = open(filepath, 'w')

#critical section to global data
def write(tt, name):
    global v1, v2
    v1.append(name)
    v2.append(tt)
    
#must not do print or anything related to Origin inside the thread function
def thread_task(lock, name):
    for _ in range(5):
        sleep(5)
        now = datetime.now()
        tt = now.strftime("%H:%M:%S.%f")[:-3]
        lock.acquire()
        write(tt, name)
        lock.release()

#global variables to be used inside thread task
v1=[]
v2=[]
#we need to have criticlal section for any access to shared data
lock = threading.Lock()

t1 = threading.Thread(target=thread_task, args=(lock,'a'))
t2 = threading.Thread(target=thread_task, args=(lock,'b'))
t1.start()
t2.start()
now1 = datetime.now()
main_file.write(f'{now1.strftime("%H:%M:%S.%f")[:-3]}: Waiting\n')
print("Waiting...")
t1.join()
t2.join()
now1 = datetime.now()
main_file.write(f'{now1.strftime("%H:%M:%S.%f")[:-3]}: Waiting done...\n')
print("Waiting done...")

#threads done, we can put data to a worksheet
wks=op.new_sheet()
#need to set col(2) as time format before putting data into it
wks.cols = 2
wks.as_time(1, 10)

wks.from_list(0, v1, 'Name')
wks.from_list(1, v2, 'Time')
#has to use LabTalk for setting column width
wks.lt_exec("wks.col2.width=9")

main_file.close()