Locking a method in Python?

python-3.x locking scheduler apscheduler
DanijelT picture DanijelT · Aug 25, 2016 · Viewed 10.6k times · Source

Here is my problem: I'm using APScheduler library to add scheduled jobs in my application. I have multiple jobs executing same code at the same time, but with different parameters. The problem occurs when these jobs access the same method at the same time which causes my program to work incorrectly.

I wanna know if there is a way to lock a method in Python 3.4 so that only one thread may access it at a time? If so, could you please post a simple example code? Thanks.

Answer

Stanislav Ivanov picture Stanislav Ivanov · Aug 25, 2016

You can use a basic python locking mechanism:

from threading import Lock
lock = Lock()
...

def foo():
    lock.acquire()
    try:
        # only one thread can execute code there
    finally:
        lock.release() #release lock

Or with context managment:

def foo():
    with lock:
        # only one thread can execute code there

For more details see Python 3 Lock Objects and Thread Synchronization Mechanisms in Python.

Related questions

python lock with-statement and timeout

I am using a Python 3 sequence like this: lock = threading.Lock() res = lock.acquire(timeout=10) if res: # do something .... lock.release() else: # do something else ... I would prefer to use a with-statement instead of explicit "acquire" and "release", but I …

Read More
Convert bytes to a string

I'm using this code to get standard output from an external program: >>> from subprocess import * >>> command_stdout = Popen(['ls', '-l'], stdout=PIPE).communicate()[0] The communicate() method returns an array of bytes: >>> …

Read More
Best way to convert string to bytes in Python 3?

There appear to be two different ways to convert a string to bytes, as seen in the answers to TypeError: 'str' does not support the buffer interface Which of these methods would be better or more Pythonic? Or is it …

Read More