مقدمة لاستخدام BlockingQueue بناءً على Java

انسخ رمز الكود كما يلي:

// الحزمة الافتراضية
import java.util.concurrent.*;

import base.MyRunnable;

اختبار الطبقة العامة
{
الفراغ العام الثابت الرئيسي (String[] args)
{
BlockingQueue<Integer> queue = new LinkedBlockingQueue<Integer>();
java.lang.Runnable r = new MyRunnable(queue);
الموضوع t = موضوع جديد (ص)؛
t.start();

بينما (صحيح)
{
يحاول
{
بينما (صحيح)
{
ل(int i =0;i < 10000;i++)
{
queue.offer(i);
}
}
}
قبض (الاستثناء ه)
{
printStackTrace();
}
}
}
}

// الحزم التي يجب إضافتها
قاعدة الحزمة؛

import java.lang.Runnable;
import java.util.concurrent.*;
import java.util.*;

الطبقة العامة MyRunnable تنفذ Runnable
{
MyRunnable العامة (قائمة انتظار BlockingQueue<Integer>)
{
this.queue = queue;
}
تشغيل الفراغ العام ()
{
التاريخ د = تاريخ جديد ()؛
وقت بدء طويل = d.getTime();
System.err.println(starttime);
عدد صحيح = 0؛
بينما (صحيح)
{
يحاول
{
عدد صحيح i = this.queue.poll();
إذا (أنا ! = فارغة)
{
العد++;
}
إذا (العدد == 100000)
{
التاريخ e = تاريخ جديد ()؛
نهاية طويلة = e.getTime();
System.err.println(count);
System.err.println(endtime);
System.err.print(endtime - starttime);
استراحة؛
}

}
قبض (الاستثناء ه)
{

}
}
}
قائمة انتظار BlockingQueue<Integer> الخاصة؛
}

انسخ رمز الكود كما يلي:

الاستطلاع الإلكتروني العام () {
عدد AtomicInteger النهائي = this.count;
إذا (count.get() == 0)
عودة فارغة؛
E x = null;
كثافة العمليات ج = -1؛
Final ReentrantLock takeLock = this.takeLock;
takeLock.lock();
يحاول {
إذا (count.get() > 0) {
س = استخراج ()؛
c = count.getAndDecrement();
إذا (ج > 1)
notEmpty.signal();
}
} أخيراً {
takeLock.unlock();
}
إذا (ج == القدرة)
signalNotFull();
العودة س؛
}

انسخ رمز الكود كما يلي:

العرض المنطقي العام (E e) {
إذا (e == null) قم برمي NullPointerException() الجديد;
عدد AtomicInteger النهائي = this.count;
إذا (count.get() == السعة)
عودة كاذبة.
كثافة العمليات ج = -1؛
Final ReentrantLock putLock = this.putLock;
putLock.lock();
يحاول {
إذا (count.get() <السعة) {
إدراج (ه)؛
c = count.getAndIncrement();
إذا (ج + 1 < السعة)
notFull.signal();
}
} أخيراً {
putLock.unlock();
}
إذا (ج==0)
signalNotEmpty();
العودة ج >= 0؛
}