Refactor thread initialization and add state variable
This commit is contained in:
@@ -13,29 +13,34 @@ from icecream import ic
|
|||||||
class BookGrabber(QThread):
|
class BookGrabber(QThread):
|
||||||
updateSignal = pyqtSignal(int, int)
|
updateSignal = pyqtSignal(int, int)
|
||||||
|
|
||||||
def __init__(
|
def __init__(self,app_id, prof_id, mode, data, parent=None):
|
||||||
self,
|
super(BookGrabber, self).__init__(parent = None)
|
||||||
mode: str = None,
|
|
||||||
data: list = None,
|
|
||||||
app_id: int = None,
|
|
||||||
prof_id: int = None,
|
|
||||||
parent=None,
|
|
||||||
):
|
|
||||||
super().__init__(parent)
|
|
||||||
self.logger = MyLogger("Worker")
|
self.logger = MyLogger("Worker")
|
||||||
self.logger.log_info("Starting worker thread")
|
self.logger.log_info("Starting worker thread")
|
||||||
|
self.data = data
|
||||||
self.app_id = app_id
|
self.app_id = app_id
|
||||||
self.prof_id = prof_id
|
self.prof_id = prof_id
|
||||||
self.mode = mode
|
self.mode = mode
|
||||||
self.data = data
|
|
||||||
self.book_id = None
|
self.book_id = None
|
||||||
self.logger.log_info(f"Worker thread started, using mode:{self.mode} and app_id:{self.app_id} and prof_id:{self.prof_id}")
|
self.state = (self.app_id, self.prof_id, self.mode, self.data)
|
||||||
ic(self.app_id)
|
ic(self.state)
|
||||||
time.sleep(2)
|
time.sleep(2)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
# def resetValues(self):
|
||||||
|
# self.app_id = None
|
||||||
|
# self.prof_id = None
|
||||||
|
# self.mode = None
|
||||||
|
# self.data = None
|
||||||
|
# self.book_id = None
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
self.db = Database()
|
self.db = Database()
|
||||||
item = 0
|
item = 0
|
||||||
for entry in self.data:
|
iterdata = self.data
|
||||||
|
print(iterdata)
|
||||||
|
for entry in iterdata:
|
||||||
signature = str(entry)
|
signature = str(entry)
|
||||||
self.logger.log_info("Processing entry: " + signature)
|
self.logger.log_info("Processing entry: " + signature)
|
||||||
|
|
||||||
@@ -55,7 +60,6 @@ class BookGrabber(QThread):
|
|||||||
state = 0
|
state = 0
|
||||||
print(len(rds.items))
|
print(len(rds.items))
|
||||||
for rds_item in rds.items:
|
for rds_item in rds.items:
|
||||||
ic(rds_item)
|
|
||||||
sign = rds_item.superlocation
|
sign = rds_item.superlocation
|
||||||
loc = rds_item.location
|
loc = rds_item.location
|
||||||
# print(item.location)
|
# print(item.location)
|
||||||
@@ -114,7 +118,6 @@ class AvailChecker(QThread):
|
|||||||
self.appnumber = appnumber
|
self.appnumber = appnumber
|
||||||
self.books = books
|
self.books = books
|
||||||
self.logger.log_info(f"Started worker with appnumber: {self.appnumber} and links: {self.links} and {len(self.books)} books...")
|
self.logger.log_info(f"Started worker with appnumber: {self.appnumber} and links: {self.links} and {len(self.books)} books...")
|
||||||
ic(self.appnumber)
|
|
||||||
time.sleep(2)
|
time.sleep(2)
|
||||||
def run(self):
|
def run(self):
|
||||||
self.db = Database()
|
self.db = Database()
|
||||||
|
|||||||
Reference in New Issue
Block a user