глобальная блокировка, вызывающая остановку моей программы - PullRequest
0 голосов
/ 28 октября 2018

Всякий раз, когда я запускаю часть моей программы, в которой есть threading.Lock, моя программа вообще перестает работать (она не падает, просто приостанавливается).

Мне нужно это, так как это сервер и несколькоклиенты могут подключаться и пытаться перезаписать данные одновременно.Во время выполнения этого был активен только один поток с подключенным к нему клиентом.Я использую это для моих баз данных Sqlite3 тоже.Я не заметил, что это вызывает проблему, так как, кажется, работает отлично, несмотря на глобальную блокировку.Все сделано в одном и том же формате

with global_lock:

Здесь начинается поток вместе с тем, как я импортирую поток

from threading import Thread, Lock
global_lock = Lock()
while True:
    conn, addr = s.accept()
    connThread = Thread(target=handler, args=(conn, addr))
    connThread.daemon = True
    connThread.start()

Вот программа

def addUser_InHash(username, password):

    print("Adding user in hash")
    hashID = 0
    hashString = username + password
    added = False
    for i in hashString:
        hashID += ord(i)
    hashID = hashID % hashKey
    print(hashID, "hashID in addUser")

    file = open("LoginHashTable.pickle", "rb+")
    if os.path.getsize("LoginHashTable.pickle") > 0:
        hashTable = pickle.load(file)
        print("File not empty,\nSaved Data:\n{}".format(hashTable))

    else:
        print("File empty")
        hashTable = {}
    count = 0

    while not added:
        print("while not count :", count)
        count += 1
        if hashID in hashTable:
            # If this index exists
            if hashID > (hashKey - 1):
                hashID = 0
            else:
                hashID += 1
                if hashID > (hashKey - 1):
                    hashID = 0

        else:
            print("User doesnt exist, adding to hash table")
            hashTable[hashID] = [username, password]
            print("New Added")
            print(hashTable)
            added = True

    print("Saving updated file addUser_InHash")

    if hashTable:
        with global_lock:
            file.seek(0)  # Move file pointer back to beginning of file
            file.truncate()  # Empty file by truncating to current file pointer position
            pickle.dump(hashTable, file)
            print(hashTable)
            print("Data saved")
            file.close()
    else:
        print("Hash table still empty, addUser_InHash")


def deleteUser_InHash(username, password):


    print("In deleteUser_InHash\nUsername: {}\nPassword: {}".format(username,password))
    dataFound = True
    hashID = 0
    count = 0
    hashString = username + password

    if os.path.getsize("LoginHashTable.pickle") > 0:
        file = open("LoginHashTable.pickle", "rb+")
        hashTable = pickle.load(file)
        print("File not empty,\nSaved Data:\n{}".format(hashTable))

    else:
        print("File empty")
        dataFound = False

    if dataFound:
        print("datafound true")
        for i in hashString:
            hashID += ord(i)
        hashID = hashID % hashKey
        print("hashID:",hashID)
        try:
            print("In try")
            while dataFound:
                print("In while, count:",count)
                if count == hashKey:
                    dataFound = False
                if hashTable[hashID] == [username,password]:
                    del hashTable[hashID]
                    print("Outside global lock")
                    with global_lock:
                        print("Inside global lock")
                        file.seek(0)  # Move file pointer back to beginning of file
                        file.truncate()  # Empty file by truncating to current file pointer position
                        pickle.dump(hashTable, file)
                        print(hashTable)
                        print("Data saved")
                        file.close()
                    print("Outside global lock")
                    print("Data updated")
                    print("User :", username, "deleted")
                    break
                else:
                    hashID += 1
                count += 1

        except IndexError:
            print("username could not be found")
            return False

    else:
        return False

Две функции вызываются в следующей последовательности:

deleteUser_InHash(username1,password1)
addUser_InHash(username2,password2)

Функция глобальной блокировки работает нормально в функции deleteUser_InHash(), но останавливает программу в addUser_InHash().

Программа зависает здесь:

{33: ['foo', 'bar'], 0: ['toni', 'tony'], 34: ['bar', 'foo'], 118: ['fo', 'la'], 8: ['Tom', 'Tom'], 262: ['Kam', 'Kam'], 258: ['yes', 'no']}
Saving updated file addUser_InHash

Вешая на строку кусок кода:

if hashTable:
    with global_lock:

Я знаю, что это правда, поскольку он никогда не доходит до операторов печати:

print(hashTable)
print("Data saved")

Внутри "addUser_InHash ()"

1 Ответ

0 голосов
/ 28 октября 2018

Примечание для всех: я изменил

global_lock = Lock()

до

global_lock = RLock()

и теперь моя программа работает нормально, я думаю, что это как-то связано с тем, что RLock позволяет потокам повторно захватывать блокировку более одного раза, хотя кажется, что обычные блокировки не могут?

Источник: https://docs.python.org/3/library/threading.html#thread-objects

...