Python3 run multiple functions in parallel

Question

def send_to_analyser(pkt):

    if OSPF_LSUpd in pkt:
        global pkt_num
        pkt_num_field = struct.pack('h', pkt_num % 65535)
        pkt_bytes = raw(pkt)
        s.sendto(pkt_num_field + pkt_bytes, ('127.0.0.1', 9527))


def packet_capture():
    print('[+] Starting sniffing the Link State Update packets of the target network...')
    pkts = sniff(filter="proto ospf", iface=veth_list, prn=send_to_analyser)


def test_thread():
    for i in range(1,10):
        print("test thread " + str(i))
        sleep(3)

s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

Above is the reduced version of my code, I wanna run packet_capture() and test_thread() in parallel, how could I do that ?

joshmeranda · Accepted Answer · 2020-08-27 02:03:00Z

1

For a simple case like this, you would whant to look at the threading package, to generate new Thread with the desired functions.

import threading

# the names are not required but can be useful for debugging if needed
# if the targets have arguments you can specify with the 'arg' argument
t_capture = threading.Thread(target=packet_capture, name="capture")
t_test = threading.Thread(target=test_thread, name="test")

# start the threads
t_capture.start()
t_thread.start()

# wait for them to finish with optional timeout in seconds
t_capture.join()
t_test.join()

answered Aug 27, 2020 at 2:03

joshmeranda

3,3112 gold badges14 silver badges28 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

Samuel Andrade · Accepted Answer · 2020-08-27 02:08:53Z

0

You could just use threading. Here is an example

import threading
import time

threadRunning = True

def test_thread1():
  while threadRunning:
    for i in range(1,5):
      print("test thread 1: " + str(i))
      time.sleep(0.5)

def test_thread2():
  while threadRunning:
    for i in range(1,5):
      print("test thread 2: " + str(i))
      time.sleep(0.33)


x = threading.Thread(target=test_thread1, args=())
x.start()
y = threading.Thread(target=test_thread2)
y.start()
time.sleep(10)
threadRunning = False
print("Stop it!")
time.sleep(2)

answered Aug 27, 2020 at 2:08

Samuel Andrade

1546 bronze badges

Collectives™ on Stack Overflow

Python3 run multiple functions in parallel

2 Answers 2

Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related