Bir vaqtda ko'p mijoz

while True:
    ulanish = tinglovchi.accept()   # bu yerda KUTADI
    malumot = ulanish.recv(1024)    # bu yerda ham KUTADI
    ulanish.sendall(javob)
    ulanish.close()

import selectors
import socket
import threading

PORT = 9960
selektor = selectors.DefaultSelector()

tinglovchi = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tinglovchi.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
tinglovchi.bind(("127.0.0.1", PORT))
tinglovchi.listen(8)
tinglovchi.setblocking(False)
selektor.register(tinglovchi, selectors.EVENT_READ, data=None)

nomlar = {}
qolgan = {"xabar": 6}


def server():
    while qolgan["xabar"] > 0:
        for kalit, _ in selektor.select(timeout=5):
            s = kalit.fileobj
            if kalit.data is None:
                ulanish, _ = s.accept()
                ulanish.setblocking(False)
                nomlar[ulanish] = f"mijoz-{len(nomlar) + 1}"
                selektor.register(ulanish, selectors.EVENT_READ,
                                  data=nomlar[ulanish])
                continue

            malumot = s.recv(1024)
            if not malumot:
                selektor.unregister(s)
                s.close()
                continue
            if malumot == b"salom":
                print(f"  {kalit.data} ulandi")
            else:
                qolgan["xabar"] -= 1
                print(f"  {kalit.data}: {malumot.decode()}")
            s.sendall(b"qabul qilindi")


oqim = threading.Thread(target=server, daemon=True)
oqim.start()

print("--- uchta mijoz ulanadi")
mijozlar = []
for i in range(3):
    m = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    m.connect(("127.0.0.1", PORT))
    m.sendall(b"salom")
    m.recv(64)          # server javob berguncha kutamiz
    mijozlar.append(m)

print("--- endi ular ARALASH tartibda yozadi")
tartib = [2, 0, 1, 2, 1, 0]
for n, i in enumerate(tartib, 1):
    mijozlar[i].sendall(f"xabar {n}".encode())
    mijozlar[i].recv(64)

oqim.join()
for m in mijozlar:
    m.close()
selektor.close()
tinglovchi.close()

print()
print("bitta oqim, bitta jarayon - lekin uchala mijoz ham xizmat oldi")

import asyncio

PORT = 9961
hisob = {"mijoz": 0}


async def ishlovchi(oqi, yoz):
    hisob["mijoz"] += 1
    nom = f"mijoz-{hisob['mijoz']}"
    print(f"  {nom} ulandi")
    while True:
        malumot = await oqi.read(100)
        if not malumot:
            break
        print(f"  {nom}: {malumot.decode()}")
        yoz.write(b"qabul qilindi")
        await yoz.drain()
    yoz.close()


async def mijoz(nom, xabarlar, kechikish):
    oqi, yoz = await asyncio.open_connection("127.0.0.1", PORT)
    for x in xabarlar:
        await asyncio.sleep(kechikish)
        yoz.write(x.encode())
        await yoz.drain()
        await oqi.read(100)
    yoz.close()
    await yoz.wait_closed()


async def asosiy():
    server = await asyncio.start_server(ishlovchi, "127.0.0.1", PORT)
    async with server:
        # Kechikishlar har xil - lekin ular BIR-BIRINI KUTMAYDI
        await asyncio.gather(
            mijoz("a", ["a-1", "a-2"], 0.03),
            mijoz("b", ["b-1", "b-2"], 0.05),
        )


asyncio.run(asosiy())
print()
print("await - boshqa vazifaga navbat berish nuqtasi")
print("oqim ham, jarayon ham qo'shilmadi")