многопроцессном SQLite ВСТАВИТЬ: «база данных заблокирована»

Question

(Пожалуйста, обратите внимание: Существует вопрос называется «SQLite3 и многопроцессорные», но этот вопрос на самом деле о многопоточности и так принято отвечать, это не duplicate)

Я реализую многопроцессорный скрипт, каждый процесс должен будет написать некоторые результаты в таблице sqlite. Моя программа продолжает сбой с database is locked (с sqlite допускается только одна модификация БД).

Вот пример того, что у меня есть:

def scan(n): 
    n = n + 1 # Some calculation 

    cur.execute("      \ 
        INSERT INTO hello \ 
        (n)    \ 
        VALUES ('"+n+"') \ 
       ") 

    con.commit() 
    con.close() 

    return True 


if __name__ == '__main__': 

    pool = Pool(processes=int(sys.argv[1])) 

    for status in pool.imap_unordered(scan, range(0,9999)): 
     if status: 
      print "ok" 

    pool.close() 

Я попытался с помощью замка, объявив замок в основной и использовать его как глобальный scan(), но это не мешало мне получать database is locked.

Каков правильный способ убедиться, что только один оператор INSERT будет выпущен одновременно в многопроцессорном скрипте Python?

EDIT:

Я бегу на Debian на базе Linux.

Answer 1

Это произойдет, если блокировка записи не может быть захвачена (по умолчанию) 5-секундным таймаутом. В общем, убедитесь, что ваш код COMMIT выполняет свои транзакции с достаточной частотой, тем самым освобождая блокировку и позволяя другим процессам иметь возможность ее захватить. Если вы хотите подождать дольше, вы можете сделать это:

db = sqlite.connect(filename, timeout=30.0) 

... ждет 30 секунд.