-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathutils.py
More file actions
64 lines (50 loc) · 1.61 KB
/
utils.py
File metadata and controls
64 lines (50 loc) · 1.61 KB
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
import imageio
import os
import numpy as np
#import cv2 as cv
#import skimage as sk
def video_reader(path='simb.mp4'):
filename = os.getcwd()+'/'+'simb.mp4'
vid = imageio.get_reader(filename, 'ffmpeg')
return vid
def video_writer(vid):
fps = vid.get_meta_data()['fps']
writer = imageio.get_writer('./cockatoo_gray.mp4', fps=fps)
for frame in vid:
writer.append_data(frame[:, :, :])
writer.close()
print(vid.get_length())
print(np.array(vid.get_data(10)).shape)
def withdraw(balance, lock):
for _ in range(10000):
lock.acquire()
balance.value = balance.value - 1
lock.release()
# function to deposit to account
def deposit(balance, lock):
for _ in range(10000):
lock.acquire()
balance.value = balance.value + 1
lock.release()
def perform_transactions():
# initial balance (in shared memory)
balance = multiprocessing.Value('i', 100)
# creating a lock object
lock = multiprocessing.Lock()
# creating new processes
p1 = multiprocessing.Process(target=withdraw, args=(balance,lock))
p2 = multiprocessing.Process(target=deposit, args=(balance,lock))
# starting processes
p1.start()
p2.start()
# wait until processes are finished
p1.join()
p2.join()
# print final balance
print("Final balance = {}".format(balance.value))
# initial balance (in shared memory)
balance = multiprocessing.Value('i', 100)
# creating a lock object
lock = multiprocessing.Lock()
if (__name__ == '__main__'):
print("Hello Utils")