Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import threading
- n = 1
- ln = threading.Lock()
- def iteracije(a,b):
- global n
- ln.acquire()
- for i in range(1,1001):
- n = a * n + b
- ln.release()
- t1 = threading.Thread(target=iteracije,args=(1,2))
- t2 = threading.Thread(target=iteracije,args=(3,7))
- t3 = threading.Thread(target=iteracije, args=(2,14))
- t1.start()
- t2.start()
- t3.start()
- t1.join()
- t2.join()
- t3.join()
- print(n)
- import threading
- import time
- import datetime
- e=threading.Event()
- def f1():
- time.sleep(10)
- print("Šumski požar prijavljen")
- e.set()
- def f2():
- e.wait()
- print("vatrogasci poslani na orediste")
- def f3():
- while e.is_set() == False :
- print("Trenutno je", datetime.datetime.now())
- time.sleep(1)
- t1=threading.Thread(target=f1)
- t2=threading.Thread(target=f2)
- t3=threading.Thread(target=f3)
- t1.start()
- t2.start()
- t3.start()
- t1.join()
- t2.join()
- t3.join()
- KLIJENT:
- import socket
- sock1 = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
- sock1.connect("/home/korisnik/sock1.socket")
- tekst = input("unesite: ")
- sock1.send(tekst.encode("UTF-8"))
- poruka = sock1.recv(4096)
- print(poruka.decode())
- SERVER:
- import socket
- sock1 = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
- sock1.bind("/home/korisnik/sock1.socket")
- while True:
- sock1.listen(0)
- sock_cli, adr_cli = sock1.accept()
- poruka = sock_cli.recv(4096)
- poruka2 = poruka.decode("UTF-8")
- brojevi = poruka2.split(",")
- br1 = int(brojevi[1])
- br2 = int(brojevi[2])
- rez = br1+br2
- rez_s = str(rez)
- rezultat = "rezultat, "
- treca = rezultat+rez_s
- print(treca)
- sock_cli.send(treca.encode("UTF-8"))
- sock_cli.close()
- import subprocess
- okolina = subprocess.call(["ls", "/home/korisnik/MOJDIR"])
- if okolina == "" and okolina == "/home/korisnik/MOJDIR":
- subprocess.run(["cd","/home/korisnik/MOJDIR"])
- else:
- subprocess.run(["cd","/home/korisnik"])
- datoteke = subprocess.call(["ls", "/home/korisnik", "|", "grep", ".txt$"])
- print(datoteke)
- import threading
- zbroj = 0
- lock_zbroj = threading.Lock()
- def pribroji(i, j):
- global zbroj
- lock_zbroj.acquire()
- for x in range(i,j):
- zbroj += x
- lock_zbroj.release()
- t1 = threading.Thread(target=pribroji, args=(1, 250001))
- t2 = threading.Thread(target=pribroji, args=(250001, 500001))
- t1.start()
- t2.start()
- t1.join()
- t2.join()
- print("zbroj iznosi:", zbroj)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement