1. Menggunakan BlockingQueue adalah cara yang paling langsung dan disyorkan untuk melaksanakan model pengeluar pengeluar Java. Ia mengendalikan penyegerakan benang secara dalaman. Pengeluar memanggil kaedah meletakkan () untuk menyekat ruang giliran menunggu, dan pengguna memanggil kaedah mengambil () untuk menyekat data menunggu; 2. Jika pelaksanaan manual memerlukan mekanisme penguncian dan tunggu/notis yang disegerakkan untuk menyelaraskan tingkah laku benang, terasnya adalah untuk menyemak syarat -syarat dan mengendalikan penampan bersama dalam blok penyegerakan; 3. Nota termasuk pengendalian yang betul, strategi bangun pelbagai threaded untuk memilih NOTIFYALL (), menetapkan saiz penampan yang munasabah, dan benang penutupan yang elegan.

Dalam pengaturcaraan Multithreaded Java, melaksanakan model pengguna-pengguna adalah model kesesuaian yang sama. Ia digunakan terutamanya untuk menyelesaikan masalah kerjasama antara pelbagai benang: satu atau lebih benang bertanggungjawab untuk "pengeluaran" data, dan satu lagi benang bertanggungjawab untuk "memakan" data ini.

Untuk melaksanakan model ini, kunci adalah bagaimana untuk melepasi data dengan selamat antara benang dan mengelakkan persaingan sumber dan masalah kebuntuan. Mari kita mulakan dari beberapa perspektif praktikal dan bercakap tentang bagaimana untuk melakukannya secara terperinci.

Menggunakan BlockingQueue adalah cara yang paling langsung

Java menyediakan antara muka BlockingQueue siap sedia (seperti ArrayBlockingQueue atau LinkedBlockingQueue ), yang telah mengendalikan masalah penyegerakan benang secara dalaman dan merupakan kaedah yang paling disyorkan untuk melaksanakan pengguna-pengguna.

Sangat mudah digunakan:

• Pengeluar memanggil kaedah put() untuk memasukkan data ke dalam barisan
• Pengguna memanggil kaedah take() untuk mendapatkan data dari barisan

Kedua -dua kaedah itu menyekat, dan apabila barisan penuh, pengeluar akan menunggu; Apabila barisan kosong, pengguna akan menunggu, yang sama seperti tingkah laku yang diingini.

Contoh coretan kod:

 BlockingQueue <Integer> giliran = baru ArrayBlockingQueue <> (10);

// Thread Pengeluar Benang baru (() -> {
    Cuba {
        int i = 0;
        sementara (benar) {
            giliran.put (i);
            System.out.println ("Dihasilkan:" i);
        }
    } tangkapan (InterruptedException e) {
        Thread.currentthread (). Interrupt ();
    }
}). Mula ();

// thread pengguna benang baru (() -> {
    Cuba {
        sementara (benar) {
            int value = queue.take ();
            System.out.println ("dimakan:" nilai);
        }
    } tangkapan (InterruptedException e) {
        Thread.currentthread (). Interrupt ();
    }
}). Mula ();

Sekiranya anda tidak menggunakan barisan siap sedia, anda boleh menambah kawalan kunci secara manual

Jika anda tidak mahu bergantung pada BlockingQueue , anda juga boleh melaksanakan logik secara manual. Pada masa ini, kata kunci synchronized dan wait/notify mekanisme perlu digunakan untuk menyelaraskan tingkah laku benang.

Idea Teras:

• Gunakan struktur data bersama (seperti List ) sebagai penampan
• Mengunci semasa mengendalikan penampan
• Apabila penampan penuh, benang pengeluar menunggu; bangun ketika ada ruang
• Apabila penampan kosong, benang pengguna menunggu; bangun apabila data baru tersedia

Nota:

• Keadaan mesti diperiksa di gelung kerana mungkin ada bangun palsu
• Memanggil wait() dan notify() mesti dilakukan di blok penyegerakan

Contoh pseudocode:

 Kelas Awam SharedBuffer {
    Senarai peribadi <Integer> buffer = arrayList baru <> ();
    persendirian int max_size = 10;

    PULIK PULIC SYNCHRONIZED PUT (INT VALUE) BROWS INGRESTEDEXception {
        sementara (buffer.size () == max_size) {
            tunggu ();
        }
        buffer.add (nilai);
        notifyAll ();
    }

    Int yang disegerakkan awam Take () melemparkan Gangguan TerrectedException {
        sementara (buffer.isempty ()) {
            tunggu ();
        }
        int value = buffer.remove (0);
        notifyAll ();
        nilai pulangan;
    }
}

Beberapa mudah diabaikan tetapi butiran penting

• Pengendalian mengganggu : Benang boleh terganggu. Ingatlah untuk menangkap InterruptedException dan memulihkan keadaan mengganggu.
• Strategi bangun dalam senario multi-pengeluar/pengguna : Sekiranya terdapat banyak benang yang menunggu, cuba gunakan notifyAll() dan bukannya notify() untuk mengelakkan hilang bangun
• Menetapkan saiz penampan yang munasabah : Terlalu besar akan membazirkan ingatan, terlalu kecil boleh menyebabkan kerap menunggu
• Benang yang elegan : Keluar gelung dapat dikawal dengan menambahkan bit bendera dan bukannya gelung tak terhingga tidak mengendalikan keadaan keluar

Pada dasarnya itu sahaja. BlockingQueue dapat dengan cepat melaksanakan fungsi, sementara pelaksanaan manual dapat membantu anda memahami mekanisme yang mendasari. Kedua -dua kaedah ini mempunyai senario mereka sendiri. Dengan memilih alat yang betul, anda boleh menulis program serentak yang stabil dan cekap.

Atas ialah kandungan terperinci Melaksanakan corak pengguna pengeluar menggunakan benang Java.. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!