Pengeluar/pengguna dengan Channels (gambaran keseluruhan)
Modelkan baris gilir pengeluar/pengguna seperti Channels menggunakan BlockingCollection : penimbal terhad (tekanan balik), berbilang pengguna dan penyelesaian yang teratur.
Pengeluar/pengguna dengan Channels (gambaran keseluruhan) ialah pelajaran Akademi C# percuma di CoddyKit. Ini ialah pelajaran 2 daripada 3. Anda boleh membaca keseluruhan pelajaran di bawah secara percuma — kemudian berlatih secara praktikal dalam pelayar menggunakan penyunting kod terbina dalam dan tutor kecerdasan buatan 24/7. Pelajaran ini merupakan sebahagian daripada laluan pembelajaran Akademi C#, dan kemajuan anda disegerakkan merentas web serta aplikasi CoddyKit. Kursus Akademi C# merangkumi sejumlah 3 pelajaran.
Konsep & matlamat
Matlamat: Bina saluran pengeluar/pengguna yang selamat.
- Idea saluran: queue antara pengeluar dan pengguna
- Kapasiti terhad memberikan tekanan balik
- Sokong berbilang pengguna
- Gunakan CompleteAdding untuk penutupan yang kemas
Seorang pengeluar/seorang pengguna
Aliran asas: pengeluar menggunakan Add, pengguna melakukan lelaran dengan GetConsumingEnumerable, kemudian gunakan CompleteAdding untuk menyelesaikannya.
using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;
public class Program
{
public static void Main(string[] args)
{
// Unbounded by default; simple demo
BlockingCollection<int> queue = new BlockingCollection<int>();
// Producer
Task producer = Task.Run(() =>
{
for (int i = 1; i <= 5; i++)
{
queue.Add(i); // enqueue
Console.WriteLine("Produced " + i);
Thread.Sleep(50); // simulate work
}
queue.CompleteAdding(); // signal no more items
});
// Consumer
Task consumer = Task.Run(() =>
{
foreach (int x in queue.GetConsumingEnumerable())
{
Console.WriteLine("Consumed " + x);
Thread.Sleep(80); // simulate processing
}
Console.WriteLine("Consumer done");
});
Task.WaitAll(producer, consumer);
}
}
Demonstrasi tekanan balik
Queue terhad mengenakan tekanan balik: apabila penuh, Add disekat sehingga pengguna menyediakan ruang.
using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;
public class Program
{
public static void Main(string[] args)
{
// Bounded capacity introduces backpressure
BlockingCollection<int> queue = new BlockingCollection<int>(boundedCapacity: 2);
Task producer = Task.Run(() =>
{
for (int i = 1; i <= 5; i++)
{
queue.Add(i); // blocks when the buffer is full
Console.WriteLine("Produced " + i + " (count=" + queue.Count + ")");
}
queue.CompleteAdding();
});
Task consumer = Task.Run(() =>
{
foreach (int x in queue.GetConsumingEnumerable())
{
Console.WriteLine("Consumed " + x);
Thread.Sleep(120); // slower consumer -> producer will block sometimes
}
});
Task.WaitAll(producer, consumer);
}
}
Pengguna pengagihan
Berbilang pengguna bersaing untuk mendapatkan item (pengagihan). Kerja dikongsi merentas utasan secara automatik.
using System;
using System.Collections.Concurrent;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
public class Program
{
public static void Main(string[] args)
{
BlockingCollection<int> queue = new BlockingCollection<int>(3);
Task prod = Task.Run(() =>
{
for (int i = 1; i <= 8; i++)
{
queue.Add(i);
Console.WriteLine("Produced " + i);
Thread.Sleep(30);
}
queue.CompleteAdding();
});
// Start 2 consumers that compete for items
Task[] consumers = Enumerable.Range(1, 2).Select(id => Task.Run(() =>
{
foreach (int x in queue.GetConsumingEnumerable())
{
Console.WriteLine("C" + id + " got " + x);
Thread.Sleep(100);
}
Console.WriteLine("C" + id + " done");
})).ToArray();
Task.WaitAll(consumers.Concat(new[] { prod }).ToArray());
}
}
Penyelesaian yang kemas
Gunakan CompleteAdding dan GetConsumingEnumerable untuk menyelesaikan proses dengan kemas apabila queue dikosongkan.
using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;
public class Program
{
static void Producer(BlockingCollection<string> q)
{
string[] lines = { "A", "B", "C", "D" };
foreach (var s in lines)
{
q.Add(s);
Console.WriteLine("Produced " + s);
}
q.CompleteAdding(); // signal completion
}
static void Consumer(BlockingCollection<string> q)
{
try
{
foreach (var item in q.GetConsumingEnumerable())
{
Console.WriteLine("Consumed " + item);
Thread.Sleep(60);
}
Console.WriteLine("Consumer finished all items");
}
catch (InvalidOperationException)
{
// Thrown if taken after completion and empty; avoided by foreach above.
}
}
public static void Main(string[] args)
{
var queue = new BlockingCollection<string>(2);
Task p = Task.Run(() => Producer(queue));
Task c = Task.Run(() => Consumer(queue));
Task.WaitAll(p, c);
}
}
Petua & perangkap
Petua:
- Utamakan penimbal terhad untuk mengelakkan pertumbuhan memori.
- Gunakan GetConsumingEnumerable untuk mengelakkan perlumbaan semasa penyelesaian.
- Pastikan item kerja kecil dan bebas; elakkan keadaan yang dikongsi.
- Catat dan kendalikan ralat dalam pengguna untuk mengelakkan pemberhentian senyap.
Tujuan CompleteAdding
Imbas kembali
Imbas kembali: Gunakan BlockingCollection terhad untuk meniru saluran, agihkan kepada berbilang pengguna, dan gunakan CompleteAdding untuk penutupan yang lancar.
Pelajari C# dengan tutor kecerdasan buatan — percuma
Tulis dan jalankan kod sebenar dalam pelayar anda, dapatkan bantuan segera daripada tutor kecerdasan buatan yang tersedia 24/7, dan sambung semula dari tempat anda berhenti di web atau dalam aplikasi.
- Kursus
- 93
- Pelajaran
- 346
Soalan Lazim
Adakah pelajaran “Pengeluar/pengguna dengan Channels (gambaran keseluruhan)” percuma?
Ya — teks penuh “Pengeluar/pengguna dengan Channels (gambaran keseluruhan)” boleh dibaca secara percuma di web ini. Untuk berlatih secara interaktif menggunakan penyunting kod terbina dalam dan tutor kecerdasan buatan 24/7, serta membuka kunci baki kursus Akademi C#, tingkat taraf kepada CoddyKit PRO. Kursus Akademi C# merangkumi sejumlah 3 pelajaran.
Apakah yang akan saya pelajari dalam “Pengeluar/pengguna dengan Channels (gambaran keseluruhan)”?
Modelkan baris gilir pengeluar/pengguna seperti Channels menggunakan BlockingCollection : penimbal terhad (tekanan balik), berbilang pengguna dan penyelesaian yang teratur. Anda berlatih Akademi C# menggunakan kod praktikal yang dijalankan terus dalam pelayar, manakala tutor kecerdasan buatan 24/7 menjawab soalan anda semasa anda mengikuti pelajaran.
Adakah saya memerlukan pengalaman untuk memulakan Akademi C#?
Tiada pengalaman terdahulu diperlukan. Pembelajaran Akademi C# di CoddyKit disusun untuk pelajar daripada peringkat pemula hingga lanjutan, jadi anda boleh bermula di sini atau dari awal dan belajar mengikut kadar anda sendiri. Ini ialah pelajaran 2 daripada 3.
Berapa lamakah pelajaran “Pengeluar/pengguna dengan Channels (gambaran keseluruhan)” diambil?
Kebanyakan pelajaran CoddyKit mengambil masa kira-kira 5–10 minit. Setiap pelajaran ringkas dan interaktif, jadi anda boleh membuat kemajuan secara berterusan dan menyambung tepat dari tempat anda berhenti di web atau aplikasi.
Bolehkah saya menulis dan menjalankan kod dalam pelajaran Akademi C# ini?
Ya. Setiap pelajaran Akademi C# menyertakan penyunting kod terbina dalam, jadi anda boleh menulis dan menjalankan kod sebenar terus dalam pelayar serta menerima maklum balas kecerdasan buatan serta-merta — tanpa memerlukan persediaan setempat.
Semua pelajaran dalam kursus ini
- Parallel.ForEach, PLINQ
- Pengeluar/pengguna dengan Channels (gambaran keseluruhan)
- Pertukaran kadar pemprosesan berbanding kependaman