Alqor — Bölmə 9: Asinxron və Paralel Proqramlaşdırma#

asinxron funksiya məlumatAl(url: mətn) -> mətn
    dəyişən cavab = gözlə http.al(url)
    qaytar cavab.mətn()
son

asinxron funksiya əsas()
    dəyişən m = gözlə məlumatAl("https://vuqar.pro/alqor/api/istifadəçilər")
    yaz(m)
son

asinxron funksiya f() -> tam
    qaytar 42
son

dəyişən g: Gələcək[tam] = f()     // hələ icra olunmayıb
dəyişən n: tam = gözlə g          // indi icra olunur və gözlənir

asinxron funksiya nümunə()
    // Ardıcıl — 3 saniyə
    dəyişən a = gözlə gecikmə(1000)
    dəyişən b = gözlə gecikmə(1000)
    dəyişən c = gözlə gecikmə(1000)

    // Paralel — 1 saniyə
    dəyişən (x, y, z) = gözlə paralel(
        gecikmə(1000),
        gecikmə(1000),
        gecikmə(1000)
    )
son

gətir paralel

// Hamısını gözlə
dəyişən nəticələr = gözlə paralel.hamısı([f1(), f2(), f3()])

// Hamısını gözlə, xətalara dözümlü
dəyişən nəticələr = gözlə paralel.hamısıNəticə([f1(), f2()])
// → [Uğur(...), Xəta(...)]

// İlk bitəni götür, qalanları ləğv et
dəyişən ilk = gözlə paralel.ilkBitən([f1(), f2()])

// İlk uğurlu olanı
dəyişən ilkUğur = gözlə paralel.ilkUğurlu([f1(), f2()])

// Məhdud paralellik (eyni anda maksimum 5)
dəyişən hamısı = gözlə paralel.məhdud(5, sorğular)

// Siyahı üzərində paralel çevirmə
dəyişən cavablar = gözlə paralel.çevir(urllər, (u) => http.al(u))

gətir vaxt

gözlə vaxt.gözlə(1000)                 // 1 saniyə gözlə (ms)
gözlə vaxt.gözləSaniyə(1.5)

// Vaxt məhdudiyyəti
dəyişən n = gözlə vaxt.limitlə(5000, uzunƏməliyyat())
// 5 saniyədən çox çəkərsə VaxtBitdiXətası

// Təkrarlanan
dəyişən taymer = vaxt.interval(1000, () => yaz("hər saniyə"))
taymer.dayandır()

// Bir dəfəlik gecikmə
vaxt.sonra(3000, () => yaz("3 saniyə sonra"))

dəyişən ləğv = yeni LəğvNişanı()

asinxron funksiya uzunİş(nişan: LəğvNişanı)
    hər i üçün 1..1000 içində
        nişan.yoxla()                   // ləğv olunubsa LəğvXətası atır
        gözlə addım(i)
    son
son

// Başqa yerdən:
ləğv.ləğvEt()

// Və ya avtomatik vaxt ilə:
dəyişən ləğv = LəğvNişanı.vaxtla(5000)

gətir sap

// Sap yaratmaq
dəyişən s = sap.başlat(funksiya()
    yaz("Paralel sapda işləyir")
    qaytar ağırHesablama()
son)

dəyişən nəticə = s.gözlə()

// Sap hovuzu
dəyişən hovuz = sap.hovuz(ölçü: 4)
dəyişən nəticələr = hovuz.xəritələ(verilənlər, (x) => emal(x))
hovuz.bağla()

// Nüvə sayı
yaz(sap.nüvəSayı())

dəyişən kanal = yeni Kanal[tam](tutum: 10)

sap.başlat(funksiya()
    hər i üçün 1..5 içində
        kanal.göndər(i)
    son
    kanal.bağla()
son)

hər dəyər üçün kanal içində
    yaz("Alındı: {dəyər}")
son

dəyişən kilid = yeni Kilid()
dəyişən sayğac = 0

funksiya artır()
    kilid.tut()
    gecikdir kilid.burax()
    sayğac += 1
son

// Və ya qısa:
funksiya artır2()
    kilid.ilə(funksiya()
        sayğac += 1
    son)
son

// Atomik tiplər (kilidsiz)
dəyişən atomSayğac = yeni Atomik[tam](0)
atomSayğac.artır()
yaz(atomSayğac.oxu())

yeni Kilid()                    // qarşılıqlı istisna (mutex)
yeni OxuYazKilidi()             // bir yazıcı / çox oxucu
yeni Semafor(5)                 // sayğaclı semafor
yeni Baryer(4)                  // 4 sap görüşənə qədər gözlə
yeni Hadisə()                   // siqnal gözləmə

gətir axın

// Asinxron iterasiya
asinxron funksiya oxu()
    hər sətir üçün fayl.axınOxu("böyük.txt") içində gözlə
        yaz(sətir)
    son
son

// Axın generatoru
asinxron generator funksiya saylar() -> tam
    hər i üçün 1..10 içində
        gözlə vaxt.gözlə(100)
        ver i
    son
son

// Axın əməliyyatları
dəyişən nəticə = gözlə saylar()
    .filtr((x) => x % 2 == 0)
    .çevir((x) => x * 10)
    .topla()

gətir dövr

// Növbəti iterasiyada icra et
dövr.növbəti(() => yaz("sonra"))

// Mikro tapşırıq
dövr.mikro(() => yaz("daha tez"))

// Hadisə dövrünü əl ilə idarə etmək (ixtisaslaşmış hallar)
dövr.işlət()
dövr.bir_addım()
dövr.dayandır()

asinxron funksiya risk()
    cəhd et
        dəyişən c = gözlə http.al("https://nümunə.az")
        yaz(c.mətn())
    tut (x: ŞəbəkəXətası)
        yaz("Şəbəkə problemi: {x.mesaj}")
    tut (x: VaxtBitdiXətası)
        yaz("Vaxt bitdi")
    nəhayət
        yaz("bitdi")
    son
son

// Paralel əməliyyatlarda
dəyişən nəticələr = gözlə paralel.hamısıNəticə([f1(), f2(), f3()])
hər n üçün nəticələr içində
    seç n
        hal Uğur(d) → yaz("OK: {d}")
        hal Xəta(x) → yaz("Xəta: {x.mesaj}")
    son
son