Лок прокси в многопотоке

[Philipp]

Подскажите что делаю не так, задача брать из базы прокси, менять статус дабы другие потоки его не использовали, если запускаю шаблон и добавляю по 1 потоку - то всё нормально, прокси лочатся как надо, но если оставляю поток поработать какое-то время - случается путаница и я уже вижу что 10 потоков работает, а залочены только 2 прокси.

Логика такая, перед работой берётся 1 прокси из базы со статусом wait, меняется статус на working, дальше чек на коннект, если нет ответа - другим кубиком прокси обратно в статус wait и берём новый, если отработал шаблон нормально, прокси в статус - wait

 

[Philipp]

@VladZen не могу вставить код, ошибку выдаёт

Упс! Мы столкнулись с некоторыми проблемами. Пожалуйста, попробуйте позже. Более детальную информацию об ошибке вы можете посмотреть в консоли браузера

 

[Phoenix78]

А где тут лок то ? это описана работа с метками в базе.

 

[Philipp]

А где тут лок то ? это описана работа с метками в базе.

Да, я это имел ввиду. Вопрос в том как найти ошибку в этих метках, есть подозрение на то, что таблица не лочится и поэтому берутся одни и те же прокси в работу

 

[Phoenix78]

Да, я это имел ввиду. Вопрос в том как найти ошибку в этих метках, есть подозрение на то, что таблица не лочится и поэтому берутся одни и те же прокси в работу

лочится не лочится, это как нам понять ? если лочишь в базе, значит где то ошибся. если лочишь в зенке, то значит что то не так сделал. а что не так.... ну нет хрустального шара...

 

[Yuriy Zymlex]

Да, я это имел ввиду. Вопрос в том как найти ошибку в этих метках, есть подозрение на то, что таблица не лочится и поэтому берутся одни и те же прокси в работу

С большой вероятностью, у вас обычная ошибка в логике блокировки таблицы.

 

[Philipp]

А как код вставить? Ошибка какая-то, я противник хрустальных шаров=))

 

[Yuriy Zymlex]

А как код вставить? Ошибка какая-то, я противник хрустальных шаров=))

А вы точно код вставляете в:

код

?

 

[Philipp]

DB db = new DB(db_host, db_user, db_pswd, db_database, db_charset);
db.query("LOCK TABLES `"+proxy_table+"` WRITE");

Не вставляет полный код, прикрепляю файлом

 

[Yuriy Zymlex]

LOCK TABLES

Если не ошибаюсь, это работает для текущего подключения, но другие потоки шаблонов создают свои подключения.

 

[Philipp]

И что с этим можно сделать?

 

[Yuriy Zymlex]

И что с этим можно сделать?

Используйте блокировку на стороне C#.

https://zennolab.com/discussion/threads/osobennosti-ispolzovanija-standartnyx-lockov-dlja-mnogopotoka.44524/

 

[Philipp]

Используйте блокировку на стороне C#.

https://zennolab.com/discussion/threads/osobennosti-ispolzovanija-standartnyx-lockov-dlja-mnogopotoka.44524/

Я правильно понмаю что нужно в общем коде создать новый объект db_locker например и выполнять подключение к базе и все манипуляции уже внутри этого лока?


lock (SyncObjects.db_locker){
Подключение и работа с базой
}

 

[Yuriy Zymlex]

Я правильно понмаю что нужно в общем коде создать новый объект db_locker например и выполнять подключение к базе и все манипуляции уже внутри этого лока?


lock (SyncObjects.db_locker){
Подключение и работа с базой
}

Да, операции получения прокси с проверкой и сменами её статуса.

 

[Philipp]

Да, операции получения прокси с проверкой и сменами её статуса.

Спасибо, помогло