cell_research/multithread_cell_sorting_analysis(deprecated).py at main · Zhangtaining/cell_research · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
# import sys, getopt
# from tkinter import *
# import threading
# from modules.multithread.StatusProbe import StatusProbe
# from modules.multithread.SelectionSortCell import SelectionSortCell
# from modules.multithread.BubbleSortCell import BubbleSortCell
# from modules.multithread.MergeSortCell import MergeSortCell
# from modules.multithread.CellGroup import CellGroup, GroupStatus
# from modules.multithread.MultiThreadCell import CellStatus
# from visualization.CellImage import CellImage
# from visualization.CellGroupImage import CellGroupImage
# import random


# # VALUE_LIST = [28, 34, 6, 20, 7, 89, 34, 18, 29, 51]
# #VALUE_LIST = range(20,0,-1)

# def create_cells_within_one_group(value_list, threadLock, swapping_count, status_probe):
#     if len(value_list) == 0:
#         return []
#     left_boundary = (0, 1)
#     right_boundary = (len(value_list) - 1, 1)
#     cells = []
#     for i in range(0, len(value_list)):
#         cell = None
#         if random.random() <= 1:
#             cell = BubbleSortCell(i + 1, value_list[i], threadLock, (i, 1), cells, left_boundary, right_boundary, status_probe, disable_visualization=True, swapping_count=swapping_count)
#         else:
#             cell = SelectionSortCell(i + 1, value_list[i], threadLock, (i, 1), cells, left_boundary, right_boundary, status_probe, disable_visualization=True, swapping_count=swapping_count)
#         cells.append(cell)

#     period = 100000000
#     start_count_down = 1000000
#     cell_group = CellGroup(cells, cells, 0, left_boundary, right_boundary, GroupStatus.ACTIVE, threadLock, start_count_down, period)
#     for cell in cells:
#         cell.group = cell_group

#     return cells, [cell_group]

# def print_current_status(cells):
#     print([{"value": c.value, "group id": c.group.group_id, "group status": c.group.status, "cell status": c.status, "left": c.left_boundary, "right": c.right_boundary} for c in cells])

# def is_sorted(cells):
#     prev_cell = cells[0]
#     for c in cells:
#         if c.value < prev_cell.value:
#             return False
#         prev_cell = c
#     return True
#     # print([{"value": c.value, "group id": c.group.group_id, "group status": c.group.status, "cell status": c.status, "left": c.left_boundary, "right": c.right_boundary} for c in cells])

# def kill_all_thread(cells, groups):
#     for c in cells:
#         c.status = CellStatus.INACTIVE

#     for g in groups:
#         g.status = GroupStatus.MERGED

# def activate(cells, cell_groups):
#     for cell in cells:
#         cell.start()

#     for group in cell_groups:
#         group.start()


# def get_pass_in_args(argv):
#     cell_type = ""
#     try:
#         opts, args = getopt.getopt(argv, "h", ["cell_type="])
#     except getopt.GetoptError:
#         print("please specify cell type using '--cell_type='")
#         sys.exit(2)

#     for opt, arg in opts:
#         if opt == "-h":
#             print("multithread_cell_sorting.py --cell_type=<cell_type>")
#             sys.exit()

#         if opt == "--cell_type":
#             cell_type = arg

#     if not cell_type:
#         print("please specify cell type using '--cell_type='")
#         sys.exit(2)

#     return cell_type

# def main(argv):
#     #cell_type = get_pass_in_args(argv)
#     swapping_counts = []
#     for i in range(100):
#         threadLock = threading.Lock()
#         print(f">>>>>>>>>>>>>>>>> Prepare cells to sort for instance {i + 1} <<<<<<<<<<<<<<<<<<<<")
#         value_list = randomlist = random.sample(range(0, 100), 50)
#         status_probe = StatusProbe()
#         cells, cell_groups = create_cells_within_one_group(value_list, threadLock, swapping_count, status_probe)
#         threadLock.acquire()
#         print("Activating cells...")
#         activate(cells, cell_groups)
#         threadLock.release()

#         # shape = canvas.create_oval(30 - 20, 30 - 20, 30 + 20, 30 + 20, fill="white")
#         # text = canvas.create_text(30, 30, text="3")
#         print("Start sorting......")
#         while not is_sorted(cells):
#             #print_current_status(cells)
#             time.sleep(0.0001)
#         threadLock.acquire()
#         kill_all_thread(cells, cell_groups)
#         threadLock.release()
#         swapping_counts.append(swapping_count[0])
#         print(">>>>>>>>>>>>>>>>> Sorting complete, killed all threads. <<<<<<<<<<<<<<<<<<<<\n")
#         time.sleep(2)

#     print(swapping_counts)


# if __name__ == "__main__":
#     main(sys.argv[1:])