Adakah coroutine digunakan dalam swool?

Coroutines digunakan dalam swool digunakan terutamanya untuk menukar sumber daya saing dalam rangkaian kepada operasi kolaboratif boleh difahami secara ringkas sebagai utas, yang lebih ringan, tetapi coroutine tidak boleh digunakan sesuai untuk memproses tugas intensif IO, perkhidmatan konkurensi tinggi, dsb.

Persekitaran pengendalian tutorial ini: sistem Windows 10, versi Swoole 4, komputer DELL G3

Adakah coroutine digunakan dalam swoole?

Coroutines digunakan dalam swoole

Apakah coroutines

Coroutines boleh difahami secara ringkas sebagai thread, tetapi thread ini dalam pengguna mod Ia tidak memerlukan penyertaan sistem pengendalian, dan kos penciptaan, pemusnahan dan penukaran adalah sangat rendah Tidak seperti benang, coroutine tidak boleh mengambil kesempatan daripada CPU berbilang teras. anda perlu bergantung pada model berbilang proses Swoole.

Ciri Coroutine

Pembangun boleh menggunakan penulisan kod segerak untuk mencapai kesan dan prestasi IO tak segerak tanpa sebarang kesedaran, mengelakkan masalah yang disebabkan oleh panggilan balik tak segerak tradisional Logik kod diskret dan terperangkap dalam berbilang lapisan panggilan balik menjadikan kod itu tidak dapat dikekalkan.

Pada masa yang sama, kerana lapisan bawah merangkumi coroutine, berbanding rangka kerja coroutine lapisan PHP tradisional, pembangun tidak perlu menggunakan kata kunci hasil untuk mengenal pasti operasi IO coroutine, jadi tidak perlu mendalami tentang semantik hasil. Memahami dan memanggil setiap peringkat diubah suai untuk menghasilkan, yang meningkatkan kecekapan pembangunan.

Coroutines sesuai untuk aplikasi intensif IO kerana coroutine dijadualkan secara automatik apabila IO disekat, mengurangkan kehilangan masa yang disebabkan oleh penyekatan IO.

Tidur 10,000 kali, baca, tulis, semak dan padam fail 10,000 kali, gunakan PDO dan MySQLi untuk berkomunikasi dengan pangkalan data 10,000 kali, buat pelayan TCP dan berbilang pelanggan berkomunikasi antara satu sama lain 10,000 kali, Daripada mencipta Pelayan UDP dan berbilang pelanggan untuk berkomunikasi antara satu sama lain 10,000 kali... semuanya dilakukan dengan sempurna dalam satu proses dan dalam masa satu saat!

Senario yang berkenaan

Perkhidmatan konkurensi tinggi, seperti sistem jualan kilat, antara muka API berprestasi tinggi, pelayan RPC, kumpulan sambungan, sembang IM, pelayan permainan, Internet Perkara, pelayan mesej tunggu.

Contoh 1:

Pengguna boleh mencipta coroutine melalui fungsi go untuk mencapai pelaksanaan serentak, seperti yang ditunjukkan dalam kod berikut:

go(function () {
    echo "one" . PHP_EOL;
});
go(function () {
    echo "two" . PHP_EOL;
});
go(function () {
    echo "three" . PHP_EOL;
});

Setiap kali go muncul, lapisan bawah akan membuat coroutine secara automatik Selepas coroutine mengeluarkan kandungan, ia akan keluar secara automatik

Contoh 2:

Melalui coroutine. Permintaan pelanggan boleh dilaksanakan secara serentak, menggunakan penjadualan apabila penyekatan IO yang disebabkan oleh penjadualan coroutine digunakan untuk mencapai perkhidmatan berprestasi tinggi Berikut adalah pelaksanaan serentak permintaan melalui mekanisme penangguhan:

go(function () {
    // 协程 MySQL 客户端
    $mysql = new Swoole\Coroutine\MySQL();
    $mysql->connect([
        'host' => '172.17.0.1',
        'user' => 'root',
        'password' => 'root',
        'database' => 'swoole',
    ]);
    $mysql->setDefer();
    $mysql->query('select sleep(2);');
    
     print_r("time1: " . time() . PHP_EOL);
    
    // 协程 Redis 客户端
    $redis = new Swoole\Coroutine\Redis();
    $redis->connect('172.17.0.1', 6379);
    $redis->setDefer();
    $redis->set('name', '张三');
    $redis->recv();
    
    print_r("time2: " . time() . PHP_EOL);
    $redis->setDefer();
    $redis->get('name');
    $res1 = $mysql->recv();
    $res2 = $redis->recv();
    print_r(['result1: ' => $res1[0]['sleep'], 'result2: ' => $res2, 'time3: ' => time()]);
});

Dengan. kod di atas Sebagai contoh, ia boleh difahami dengan mudah bahawa dalam mod penangguhan, respons permintaan berbilang pelanggan adalah serentak Selepas menetapkan setDefer(true), permintaan yang dimulakan melalui klien Redis atau MySQL tidak lagi akan menunggu pelayan mengembalikannya. keputusan, tetapi akan menghantar permintaan Selepas itu, kembali benar dengan serta-merta. Selepas ini, anda boleh terus memulakan permintaan Redis dan MySQL yang lain, dan akhirnya menggunakan kaedah recv() untuk menerima kandungan respons.

Nota

Jika pelanggan coroutine yang sama dikongsi antara berbilang coroutine, prosedur penyekatan penyegerakan adalah berbeza dan proses coroutine meminta secara serentak, jadi sama Mungkin terdapat banyak permintaan diproses secara selari Setelah sambungan klien dikongsi, kekeliruan data akan berlaku antara coroutine yang berbeza.

Coroutines menyegerakkan logik tak segerak yang asal, tetapi penukaran coroutine berlaku secara tersirat, jadi ketekalan pembolehubah global dan pembolehubah statik tidak boleh dijamin sebelum dan selepas penukaran coroutine.

Pembelajaran yang disyorkan: tutorial swole

Atas ialah kandungan terperinci Adakah coroutine digunakan dalam swool?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!