Merge pull request 'kalyshev_yan_lab_6' (#235) from kalyshev_yan_lab_6 into main
Reviewed-on: #235
This commit is contained in:
commit
1648f5995a
10
kalyshev_yan_lab_6/Dockerfile
Normal file
10
kalyshev_yan_lab_6/Dockerfile
Normal file
@ -0,0 +1,10 @@
|
|||||||
|
FROM python:3
|
||||||
|
|
||||||
|
WORKDIR /usr/src/app
|
||||||
|
|
||||||
|
COPY requirements.txt ./
|
||||||
|
RUN pip install --no-cache-dir -r requirements.txt
|
||||||
|
|
||||||
|
COPY . .
|
||||||
|
|
||||||
|
CMD [ "python", "./main.py" ]
|
22
kalyshev_yan_lab_6/README.md
Normal file
22
kalyshev_yan_lab_6/README.md
Normal file
@ -0,0 +1,22 @@
|
|||||||
|
# Отчет. Лабораторная работа 6
|
||||||
|
|
||||||
|
## Описание
|
||||||
|
|
||||||
|
В ходе лабораторной работы были реализованы алгоритмы нахождение детерминанта квадратной матрицы на python: обычный и параллельный.
|
||||||
|
|
||||||
|
![result](./images/result.png)
|
||||||
|
Из результатов видно, что на маленьких матрицах параллелизм не имеет смысла, но с увеличением размера матриц, время обработки значительно падает по сравнению с обычным алгоритмом.
|
||||||
|
|
||||||
|
## Как запустить
|
||||||
|
|
||||||
|
Для того, чтобы запустить сервисы, необходимо выполнить следующие действия:
|
||||||
|
|
||||||
|
1. Установить и запустить Docker Engine или Docker Desktop
|
||||||
|
2. Через консоль перейти в папку, в которой расположен файл docker-compose.yml
|
||||||
|
3. Выполнить команду для запуска:
|
||||||
|
|
||||||
|
```
|
||||||
|
docker compose up -d
|
||||||
|
```
|
||||||
|
|
||||||
|
Видео можно посмотреть по ссылке: [видео](https://zyzf.space/s/CjaXNQDkoPp9GzC).
|
3
kalyshev_yan_lab_6/docker-compose.yml
Normal file
3
kalyshev_yan_lab_6/docker-compose.yml
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
services:
|
||||||
|
main:
|
||||||
|
build: .
|
BIN
kalyshev_yan_lab_6/images/result.png
Normal file
BIN
kalyshev_yan_lab_6/images/result.png
Normal file
Binary file not shown.
After Width: | Height: | Size: 99 KiB |
82
kalyshev_yan_lab_6/main.py
Normal file
82
kalyshev_yan_lab_6/main.py
Normal file
@ -0,0 +1,82 @@
|
|||||||
|
from multiprocessing import Pool, cpu_count
|
||||||
|
import time
|
||||||
|
import numpy as np
|
||||||
|
|
||||||
|
|
||||||
|
def determinant(matrix):
|
||||||
|
matrix = np.array(matrix, dtype=float)
|
||||||
|
n = matrix.shape[0]
|
||||||
|
|
||||||
|
for i in range(n):
|
||||||
|
if matrix[i, i] == 0:
|
||||||
|
for j in range(i + 1, n):
|
||||||
|
if matrix[j, i] != 0:
|
||||||
|
matrix[[i, j]] = matrix[[j, i]]
|
||||||
|
break
|
||||||
|
if matrix[i, i] == 0:
|
||||||
|
return 0
|
||||||
|
|
||||||
|
for j in range(i + 1, n):
|
||||||
|
factor = matrix[j, i] / matrix[i, i]
|
||||||
|
matrix[j] -= factor * matrix[i]
|
||||||
|
|
||||||
|
det = 1.0
|
||||||
|
for i in range(n):
|
||||||
|
det *= matrix[i, i]
|
||||||
|
return det
|
||||||
|
|
||||||
|
|
||||||
|
def _determinant_parallel_chunk(args):
|
||||||
|
matrix, start_row, end_row = args
|
||||||
|
n = matrix.shape[0]
|
||||||
|
for i in range(start_row, end_row):
|
||||||
|
for j in range(i + 1, n):
|
||||||
|
factor = matrix[j, i] / matrix[i, i]
|
||||||
|
matrix[j] -= factor * matrix[i]
|
||||||
|
return matrix
|
||||||
|
|
||||||
|
|
||||||
|
def determinant_parallel(matrix, num_processes=None):
|
||||||
|
if num_processes is None:
|
||||||
|
num_processes = cpu_count()
|
||||||
|
|
||||||
|
matrix = np.array(matrix, dtype=float)
|
||||||
|
n = matrix.shape[0]
|
||||||
|
|
||||||
|
chunk_size = n // num_processes
|
||||||
|
tasks = [
|
||||||
|
(
|
||||||
|
matrix.copy(),
|
||||||
|
i * chunk_size,
|
||||||
|
(i + 1) * chunk_size if i != num_processes - 1 else n,
|
||||||
|
)
|
||||||
|
for i in range(num_processes)
|
||||||
|
]
|
||||||
|
|
||||||
|
with Pool(processes=num_processes) as pool:
|
||||||
|
results = pool.map(_determinant_parallel_chunk, tasks)
|
||||||
|
|
||||||
|
# В каждой части делаем лишь частичное вычитание
|
||||||
|
# Теперь выполняем окончательное вычисление детерминанта
|
||||||
|
det = 1.0
|
||||||
|
for i in range(n):
|
||||||
|
det *= results[0][i, i]
|
||||||
|
return det
|
||||||
|
|
||||||
|
|
||||||
|
sizes = [100, 300, 500]
|
||||||
|
NUM_PROCESSES = 12
|
||||||
|
|
||||||
|
for size in sizes:
|
||||||
|
A = np.random.rand(size, size)
|
||||||
|
start_time = time.time()
|
||||||
|
det_seq = determinant(A)
|
||||||
|
seq_time = time.time() - start_time
|
||||||
|
|
||||||
|
start_time = time.time()
|
||||||
|
det_par = determinant_parallel(A, num_processes=NUM_PROCESSES)
|
||||||
|
par_time = time.time() - start_time
|
||||||
|
|
||||||
|
print(
|
||||||
|
f"Size {size}x{size}: Sequential Time = {seq_time:.4f} s, Parallel Time = {par_time:.4f} s"
|
||||||
|
)
|
1
kalyshev_yan_lab_6/requirements.txt
Normal file
1
kalyshev_yan_lab_6/requirements.txt
Normal file
@ -0,0 +1 @@
|
|||||||
|
numpy
|
Loading…
Reference in New Issue
Block a user