مقدمة إلى مقاطعة حظر سلاسل المحادثات في جافا واستخدام LockSupport

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

فئة عامة TaskRunner تنفذ Runnable {
قائمة انتظار BlockingQueue<Task> الخاصة؛
عامة TaskRunner(BlockingQueue<Task> queue) {
this.queue = queue;
}
تشغيل الفراغ العام () {
يحاول {
بينما (صحيح) {
مهمة المهمة = queue.take(10, TimeUnit.SECONDS);
Task.execute();
}
}
قبض على (InterruptedException ه) {
// استعادة حالة المقاطعة
Thread.currentThread().interrupt();
}
}
}

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

فئة عامة TaskRunner تنفذ Runnable {
قائمة انتظار BlockingQueue<Task> الخاصة؛
عامة TaskRunner(BlockingQueue<Task> queue) {
this.queue = queue;
}
تشغيل الفراغ العام () {
يحاول {
بينما (صحيح) {
مهمة المهمة = queue.take(10, TimeUnit.SECONDS);
Task.execute();
}
}
قبض على (InterruptedException ه) {
// استعادة حالة المقاطعة
Thread.currentThread().interrupt();
}
}
}

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

الطبقة العامة PrimeProducer تمتد الموضوع {
قائمة انتظار BlockingQueue<BigInteger> النهائية الخاصة؛
PrimeProducer(BlockingQueue<BigInteger> queue) {
this.queue = queue;
}
تشغيل الفراغ العام () {
يحاول {
BigInteger p = BigInteger.ONE;
بينما (!Thread.currentThread().isInterrupted())
queue.put(p = p.nextProbablePrime());
} قبض (تم استهلاك InterruptedException) {
/* السماح للخيط بالخروج */
}
}
public void Cancel() {rupt(); } // بدء المقاطعة
}<SPAN style="WHITE-SPACE: Normal"> </SPAN>

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

الطبقة العامة PrimeProducer تمتد الموضوع {
قائمة انتظار BlockingQueue<BigInteger> النهائية الخاصة؛
PrimeProducer(BlockingQueue<BigInteger> queue) {
this.queue = queue;
}
تشغيل الفراغ العام () {
يحاول {
BigInteger p = BigInteger.ONE;
بينما (!Thread.currentThread().isInterrupted())
queue.put(p = p.nextProbablePrime());
} قبض (تم استهلاك InterruptedException) {
/* السماح للخيط بالخروج */
}
}
public void Cancel() {rupt(); } // بدء المقاطعة
}<SPAN style="WHITE-SPACE: Normal"> </SPAN>

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

واجهة InterruptAble { // تحديد واجهة قابلة للمقاطعة
مقاطعة الفراغ العام () تطرح InterruptedException؛
}
فئة مجردة InterruptSupport تنفذ InterruptAble {
منطقية متطايرة خاصة تمت مقاطعتها = خطأ؛
مقاطعة خاصة قابلة للمقاطعة = مقاطعة جديدة () {
مقاطعة الفراغ العام () {
متقطع = صحيح؛
InterruptSupport.this.interrupt(); // الموضع 3
}
};
تنفيذ منطقي نهائي عام () يلقي InterruptedException {
يحاول {
blockedOn(interruptor);// الموضع 1
إذا (Thread.currentThread().isInterrupted()) { // تمت مقاطعته على الفور
Interruptor.interrupt();
}
// تنفيذ كود العمل
عمل();
} أخيراً {
blockedOn(null);
}
انقطعت العودة؛
}
الملخص العام باطلة الأعمال () ؛
مقاطعة باطلة مجردة عامة () ؛
// -- sun.misc.SharedSecrets --
static void blockedOn(Interruptible intr) { // package-private
sun.misc.SharedSecrets.getJavaLangAccess().blockedOn(Thread.currentThread(), intr);
}
}

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

واجهة InterruptAble { // تحديد واجهة قابلة للمقاطعة
مقاطعة الفراغ العام () تطرح InterruptedException؛
}
فئة مجردة InterruptSupport تنفذ InterruptAble {
منطقية متطايرة خاصة تمت مقاطعتها = خطأ؛
مقاطعة خاصة قابلة للمقاطعة = مقاطعة جديدة () {
مقاطعة الفراغ العام () {
متقطع = صحيح؛
InterruptSupport.this.interrupt(); // الموضع 3
}
};
تنفيذ منطقي نهائي عام () يلقي InterruptedException {
يحاول {
blockedOn(interruptor);// الموضع 1
إذا (Thread.currentThread().isInterrupted()) { // تمت مقاطعته على الفور
Interruptor.interrupt();
}
// تنفيذ كود العمل
عمل();
} أخيراً {
blockedOn(null);
}
انقطعت العودة؛
}
الملخص العام باطلة الأعمال () ؛
مقاطعة باطلة مجردة عامة () ؛
// -- sun.misc.SharedSecrets --
static void blockedOn(Interruptible intr) { // package-private
sun.misc.SharedSecrets.getJavaLangAccess().blockedOn(Thread.currentThread(), intr);
}
}

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

فئة InterruptRead تمتد InterruptSupport {
FileInputStream الخاص في؛
@تجاوز
الأعمال التجارية باطلة العامة () {
File file = new File("/dev/urandom"); // اقرأ الثقب الأسود لنظام Linux، ولا تنتهي من القراءة أبدًا
يحاول {
in = new FileInputStream(file);
بايت[] بايت = بايت جديد[1024];
بينما (in.read(bytes, 0, 1024) > 0) {
// Thread.sleep(100);
// if (Thread.interrupted()) {// طريقة التحقق من المقاطعة السابقة
// طرح InterruptedException الجديد("");
// }
}
} قبض (الاستثناء ه) {
رمي RuntimeException (e) الجديد ؛
}
}
public FileInputStream getIn() {
العودة في؛
}
@تجاوز
مقاطعة الفراغ العام () {
يحاول {
in.getChannel().إغلاق();
} قبض (IOException ه) {
printStackTrace();
}
}
}
public static void main(String args[]) يطرح الاستثناء {
اختبار InterruptRead النهائي = New InterruptRead();
الموضوع ر = الموضوع الجديد () {
@تجاوز
تشغيل الفراغ العام () {
بداية طويلة = System.currentTimeMillis();
يحاول {
System.out.println("بدء مقاطعة القراءة!");
test.execute();
} قبض على (InterruptedException e) {
System.out.println("نهاية InterruptRead! وقت التكلفة:" + (System.currentTimeMillis() - start));
printStackTrace();
}
}
};
t.start();
// دع القراءة تنفذ لمدة 3 ثوانٍ أولاً
Thread.sleep(3000);
// إصدار مقاطعة
t.interrupt();
}

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

فئة InterruptRead تمتد InterruptSupport {
FileInputStream الخاص في؛
@تجاوز
الأعمال التجارية باطلة العامة () {
File file = new File("/dev/urandom"); // اقرأ الثقب الأسود لنظام Linux، ولا تنتهي من القراءة أبدًا
يحاول {
in = new FileInputStream(file);
بايت[] بايت = بايت جديد[1024];
بينما (in.read(bytes, 0, 1024) > 0) {
// Thread.sleep(100);
// if (Thread.interrupted()) {// طريقة التحقق من المقاطعة السابقة
// طرح InterruptedException الجديد("");
// }
}
} قبض (الاستثناء ه) {
رمي RuntimeException (e) الجديد ؛
}
}
public FileInputStream getIn() {
العودة في؛
}
@تجاوز
مقاطعة الفراغ العام () {
يحاول {
in.getChannel().إغلاق();
} قبض (IOException ه) {
printStackTrace();
}
}
}
public static void main(String args[]) يطرح الاستثناء {
اختبار InterruptRead النهائي = New InterruptRead();
الموضوع ر = الموضوع الجديد () {
@تجاوز
تشغيل الفراغ العام () {
بداية طويلة = System.currentTimeMillis();
يحاول {
System.out.println("بدء مقاطعة القراءة!");
test.execute();
} قبض على (InterruptedException e) {
System.out.println("نهاية InterruptRead! وقت التكلفة:" + (System.currentTimeMillis() - start));
printStackTrace();
}
}
};
t.start();
// دع القراءة تنفذ لمدة 3 ثوانٍ أولاً
Thread.sleep(3000);
// إصدار مقاطعة
t.interrupt();
}

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

sun.misc.SharedSecrets.setJavaLangAccess(new sun.misc.JavaLangAccess(){
public sun.reflect.ConstantPool getConstantPool(Class klass) {
إرجاع klass.getConstantPool();
}
public void setAnnotationType(Class klass, AnnotationType type) {
klass.setAnnotationType(type);
}
نوع التعليق التوضيحي العام getAnnotationType(Class klass) {
إرجاع klass.getAnnotationType();
}
عام <E يمتد التعداد<E>>
E[] getEnumConstantsShared(Class<E> klass) {
إرجاع klass.getEnumConstantsShared();
}
الفراغ العام المحظور (Thread t، Interruptible b) {
t.blockedOn(b);
}
});

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

sun.misc.SharedSecrets.setJavaLangAccess(new sun.misc.JavaLangAccess(){
public sun.reflect.ConstantPool getConstantPool(Class klass) {
إرجاع klass.getConstantPool();
}
public void setAnnotationType(Class klass, AnnotationType type) {
klass.setAnnotationType(type);
}
نوع التعليق التوضيحي العام getAnnotationType(Class klass) {
إرجاع klass.getAnnotationType();
}
عام <E يمتد التعداد<E>>
E[] getEnumConstantsShared(Class<E> klass) {
إرجاع klass.getEnumConstantsShared();
}
الفراغ العام المحظور (Thread t، Interruptible b) {
t.blockedOn(b);
}
});

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

مقاطعة الفراغ العام () {
إذا (هذا!= Thread.currentThread())
checkAccess();
متزامن (blockerLock) {
قابل للمقاطعة ب = مانع؛
إذا (ب ! = فارغة) {
Interrupt0(); // فقط لتعيين علامة المقاطعة
b.interrupt(); // خطاف رد الاتصال
يعود؛
}
}
المقاطعة0();
}

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

مقاطعة الفراغ العام () {
إذا (هذا!= Thread.currentThread())
checkAccess();
متزامن (blockerLock) {
قابل للمقاطعة ب = مانع؛
إذا (ب ! = فارغة) {
Interrupt0(); // فقط لتعيين علامة المقاطعة
b.interrupt(); // خطاف رد الاتصال
يعود؛
}
}
المقاطعة0();
}

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

إذا (Thread.interrupt()) // يمسح حالة المقاطعة!
رمي InterruptedException () الجديد ؛

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

إذا (Thread.interrupt()) // يمسح حالة المقاطعة!
رمي InterruptedException () الجديد ؛

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

متنزه الفراغ الثابت العام (حاجب الكائنات) {
الموضوع t = Thread.currentThread();
setBlocker(t, blocker); // قم بتعيين قيمة خاصية Thread.parkBlocker
unsafe.park(false, 0L);
setBlocker(t, null); // امسح قيمة خاصية Thread.parkBlocker
}

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

متنزه الفراغ الثابت العام (حاجب الكائنات) {
الموضوع t = Thread.currentThread();
setBlocker(t, blocker); // قم بتعيين قيمة خاصية Thread.parkBlocker
unsafe.park(false, 0L);
setBlocker(t, null); // امسح قيمة خاصية Thread.parkBlocker
}

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

package com.agapple.cocurrent;
استيراد java.io.File؛
استيراد java.io.FileInputStream؛
import java.lang.reflect.Field;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;
الطبقة العامة LockSupportTest {
مانع LockSupportTest الخاص الثابت = new LockSupportTest();
public static void main(String args[]) يطرح الاستثناء {
lockSupportTest();
parkTest();
IntertParkTest();
مقاطعةSleepTest();
InterruptWaitTest();
}
/**
* بعد كائن LockSupport.park، حاول الحصول على كائن Thread.blocker واستدعاء التنبيه الفردي الخاص به
*
* @throwsException
*/
قفل الفراغ الثابت الخاصSupportTest() يلقي استثناء {
الموضوع t = doTest(new TestCallBack() {
@تجاوز
رد الاتصال العام الفارغ () يلقي الاستثناء {
// حاول النوم 5S
System.out.println("blocker");
LockSupport.park(blocker);
System.out.println("استيقظ الآن!");
}
@تجاوز
سلسلة عامة getName () {
إرجاع "lockSupportTest"؛
}
});
t.start(); // ابدأ موضوع القراءة
Thread.sleep(150);
متزامن (مانع) {
حقل الحقل = Thread.class.getDeclaredField("parkBlocker");
field.setAccessible(true);
Object fBlocker = field.get(t);
System.out.println(blocker == fBlocker);
Thread.sleep(100);
System.out.println("notifyAll");
blocker.notifyAll();
}
}
/**
* إذا حاولت مقاطعة object.wait()، فسيتم طرح InterruptedException المطابق.
*
* @throws InterruptedException
*/
مقاطعة باطلة ثابتة خاصة () تطرح InterruptedException {
الكائن النهائي obj = كائن جديد ()؛
الموضوع t = doTest(new TestCallBack() {
@تجاوز
رد الاتصال العام الفارغ () يلقي الاستثناء {
// حاول النوم 5S
obj.wait();
System.out.println("استيقظ الآن!");
}
@تجاوز
سلسلة عامة getName () {
إرجاع "interruptWaitTest"؛
}
});
t.start(); // ابدأ موضوع القراءة
Thread.sleep(2000);
t.interrupt(); // التحقق من الاستجابة للمقاطعة أثناء الإيقاف
}
/**
* إذا حاولت مقاطعة Thread.sleep()، فسيتم طرح InterruptedException المطابق.
*
* @throws InterruptedException
*/
مقاطعة باطلة ثابتة خاصة () تطرح InterruptedException {
الموضوع t = doTest(new TestCallBack() {
@تجاوز
رد الاتصال العام الفارغ () يلقي الاستثناء {
// حاول النوم 5S
Thread.sleep(5000);
System.out.println("استيقظ الآن!");
}
@تجاوز
سلسلة عامة getName () {
إرجاع "interruptSleepTest"؛
}
});
t.start(); // ابدأ موضوع القراءة
Thread.sleep(2000);
t.interrupt(); // التحقق من الاستجابة للمقاطعة أثناء الإيقاف
}
/**
* حاول مقاطعة LockSupport.park()، ستكون هناك استجابة ولكن لن يتم طرح استثناء InterruptedException
*
* @throws InterruptedException
*/
مقاطعة باطلة ثابتة خاصة () يلقي InterruptedException {
الموضوع t = doTest(new TestCallBack() {
@تجاوز
رد الاتصال العام الفارغ () {
// حاول إيقاف موضوعك الخاص
LockSupport.parkNanos(blocker, TimeUnit.SECONDS.toNanos(5));
System.out.println("استيقظ الآن!");
}
@تجاوز
سلسلة عامة getName () {
إرجاع "interruptParkTest"؛
}
});
t.start(); // ابدأ موضوع القراءة
Thread.sleep(2000);
t.interrupt(); // التحقق من الاستجابة للمقاطعة أثناء الإيقاف
}
/**
* حاول مقاطعة LockSupport.unPark()، سيكون هناك رد
*
* @throws InterruptedException
*/
يلقي parkTest () الفراغ الثابت الخاص InterruptedException {
الموضوع t = doTest(new TestCallBack() {
@تجاوز
رد الاتصال العام الفارغ () {
// حاول إيقاف موضوعك الخاص
LockSupport.park(blocker);
System.out.println("استيقظ الآن!");
}
@تجاوز
سلسلة عامة getName () {
إرجاع "parkTest" ؛
}
});
t.start(); // ابدأ موضوع القراءة
Thread.sleep(2000);
LockSupport.unpark(t);
t.interrupt();
}
مؤشر ترابط عام ثابت doTest (استدعاء TestCallBack النهائي) {
إرجاع موضوع جديد () {
@تجاوز
تشغيل الفراغ العام () {
File file = new File("/dev/urandom"); // قراءة الثقب الأسود في Linux
يحاول {
FileInputStream in = new FileInputStream(file);
بايت[] بايت = بايت جديد[1024];
بينما (in.read(bytes, 0, 1024) > 0) {
إذا (Thread.interrupt()) {
رمي InterruptedException("");
}
System.out.println(بايت[0]);
Thread.sleep(100);
بداية طويلة = System.currentTimeMillis();
call.callback();
System.out.println(call.getName() + "تكلفة إنهاء رد الاتصال:"
+ (System.currentTimeMillis() - start));
}
} قبض (الاستثناء ه) {
printStackTrace();
}
}
};
}
}
واجهة اختبار CallBack {
رد الاتصال باطلة عامة () يلقي استثناء؛
سلسلة عامة getName();
}

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

package com.agapple.cocurrent;
استيراد java.io.File؛
استيراد java.io.FileInputStream؛
import java.lang.reflect.Field;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;
الطبقة العامة LockSupportTest {
مانع LockSupportTest الخاص الثابت = new LockSupportTest();
public static void main(String args[]) يطرح الاستثناء {
lockSupportTest();
parkTest();
IntertParkTest();
مقاطعةSleepTest();
InterruptWaitTest();
}
/**
* بعد كائن LockSupport.park، حاول الحصول على كائن Thread.blocker واستدعاء التنبيه الفردي الخاص به
*
* @throwsException
*/
قفل الفراغ الثابت الخاصSupportTest() يلقي استثناء {
الموضوع t = doTest(new TestCallBack() {
@تجاوز
رد الاتصال العام الفارغ () يلقي الاستثناء {
// حاول النوم 5S
System.out.println("blocker");
LockSupport.park(blocker);
System.out.println("استيقظ الآن!");
}
@تجاوز
سلسلة عامة getName () {
إرجاع "lockSupportTest"؛
}
});
t.start(); // ابدأ موضوع القراءة
Thread.sleep(150);
متزامن (مانع) {
حقل الحقل = Thread.class.getDeclaredField("parkBlocker");
field.setAccessible(true);
Object fBlocker = field.get(t);
System.out.println(blocker == fBlocker);
Thread.sleep(100);
System.out.println("notifyAll");
blocker.notifyAll();
}
}
/**
* إذا حاولت مقاطعة object.wait()، فسيتم طرح InterruptedException المقابل.
*
* @throws InterruptedException
*/
مقاطعة باطلة ثابتة خاصة () تطرح InterruptedException {
الكائن النهائي obj = كائن جديد ()؛
الموضوع t = doTest(new TestCallBack() {
@تجاوز
رد الاتصال العام الفارغ () يلقي الاستثناء {
// حاول النوم 5S
obj.wait();
System.out.println("استيقظ الآن!");
}
@تجاوز
سلسلة عامة getName () {
إرجاع "interruptWaitTest"؛
}
});
t.start(); // ابدأ موضوع القراءة
Thread.sleep(2000);
t.interrupt(); // التحقق من الاستجابة للمقاطعة أثناء الإيقاف
}
/**
* إذا حاولت مقاطعة Thread.sleep()، فسيتم طرح InterruptedException المطابق.
*
* @throws InterruptedException
*/
مقاطعة باطلة ثابتة خاصة () تطرح InterruptedException {
الموضوع t = doTest(new TestCallBack() {
@تجاوز
رد الاتصال العام الفارغ () يلقي الاستثناء {
// حاول النوم 5S
Thread.sleep(5000);
System.out.println("استيقظ الآن!");
}
@تجاوز
سلسلة عامة getName () {
إرجاع "interruptSleepTest"؛
}
});
t.start(); // ابدأ موضوع القراءة
Thread.sleep(2000);
t.interrupt(); // التحقق من الاستجابة للمقاطعة أثناء الإيقاف
}
/**
* حاول مقاطعة LockSupport.park()، ستكون هناك استجابة ولكن لن يتم طرح استثناء InterruptedException
*
* @throws InterruptedException
*/
مقاطعة باطلة ثابتة خاصة () يلقي InterruptedException {
الموضوع t = doTest(new TestCallBack() {
@تجاوز
رد الاتصال العام الفارغ () {
// حاول إيقاف موضوعك الخاص
LockSupport.parkNanos(blocker, TimeUnit.SECONDS.toNanos(5));
System.out.println("استيقظ الآن!");
}
@تجاوز
سلسلة عامة getName () {
إرجاع "interruptParkTest"؛
}
});
t.start(); // ابدأ موضوع القراءة
Thread.sleep(2000);
t.interrupt(); // التحقق من الاستجابة للمقاطعة أثناء الإيقاف
}
/**
* حاول مقاطعة LockSupport.unPark()، سيكون هناك رد
*
* @throws InterruptedException
*/
يلقي parkTest () الفراغ الثابت الخاص InterruptedException {
الموضوع t = doTest(new TestCallBack() {
@تجاوز
رد الاتصال العام الفارغ () {
// حاول إيقاف موضوعك الخاص
LockSupport.park(blocker);
System.out.println("استيقظ الآن!");
}
@تجاوز
سلسلة عامة getName () {
إرجاع "parkTest" ؛
}
});
t.start(); // ابدأ موضوع القراءة
Thread.sleep(2000);
LockSupport.unpark(t);
t.interrupt();
}
مؤشر ترابط عام ثابت doTest (استدعاء TestCallBack النهائي) {
إرجاع موضوع جديد () {
@تجاوز
تشغيل الفراغ العام () {
File file = new File("/dev/urandom"); // قراءة الثقب الأسود في Linux
يحاول {
FileInputStream in = new FileInputStream(file);
بايت[] بايت = بايت جديد[1024];
بينما (in.read(bytes, 0, 1024) > 0) {
إذا (Thread.interrupt()) {
رمي InterruptedException("");
}
System.out.println(بايت[0]);
Thread.sleep(100);
بداية طويلة = System.currentTimeMillis();
call.callback();
System.out.println(call.getName() + "تكلفة إنهاء رد الاتصال:"
+ (System.currentTimeMillis() - start));
}
} قبض (الاستثناء ه) {
printStackTrace();
}
}
};
}
}
واجهة اختبار CallBack {
رد الاتصال باطلة عامة () يلقي استثناء؛
سلسلة عامة getName();
}