starnakin/AOC
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add: multhread

Browse Source
This commit is contained in:
starnakin 2023-12-05 10:49:36 +01:00
parent 4d2161f5b1
commit bf896841d2
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
2023/day05/src/part2.py
View File

@ -1,7 +1,7 @@
import threading import threading
import time import time
text: str = open("example.txt", "r").read() text: str = open("input.txt", "r").read()
_value: int = 0 _value: int = 0
@ -57,19 +57,19 @@ def get_min_in_range(lst_conversions, start, stop):
min_value = do_all_convertions(lst_conversions, start) min_value = do_all_convertions(lst_conversions, start)
i = start + 1; i = start + 1;
while (i != stop): while (i != stop):
if ((i - start) % 10000 == 0):
display_duration(10000, stop - start)
print(i - start, '/', stop - start)
value = do_all_convertions(lst_conversions, i) value = do_all_convertions(lst_conversions, i)
#print(min_value, value, min(value, min_value)) #print(min_value, value, min(value, min_value))
min_value = min(value, min_value) min_value = min(value, min_value)
i += 1 i += 1
return (min_value) return (min_value)
CHUNK_SIZE = 10
values = [] values = []
def thread_process(convertions, start_value, chunk):
global values
values.append(get_min_in_range(convertions, start_value, chunk))
CHUNK_SIZE = 10
for current_range in current_ranges: for current_range in current_ranges:
start, stop = current_range start, stop = current_range
i = start i = start
@ -83,7 +83,10 @@ for current_range in current_ranges:
start_value = start start_value = start
i = 0 i = 0
while (i < len(chunks)): while (i < len(chunks)):
values.append(get_min_in_range(convertions, start_value, chunks[i])) t = threading.Thread(target=thread_process, args=(convertions, start_value, chunks[i]))
t.start()
display_duration(1, len(chunks))
print(i, '/', len(chunks))
i += 1 i += 1
start_value = chunks[i - 1] start_value = chunks[i - 1]