หน้าแรก>บทช่วยสอนการเขียนโปรแกรมเครือข่าย>การสอนจาวา

รู้เบื้องต้นเกี่ยวกับการใช้ BlockingQueue บน Java

ผู้เขียน：Eve Cole เวลาอัปเดต：2024-11-18 14:48:02

ล่าสุด ฉันกำลังดูแลโปรเจ็กต์ Java และในกลุ่มเรากำลังพูดคุยเกี่ยวกับข้อดีข้อเสียของ Java! น่าเสียดายที่แฟนตัวยงของ Java บางคนมักอ้างว่าประสิทธิภาพไม่ได้แย่เท่ากับ C++ อีกต่อไป และไลบรารีมาตรฐานจำนวนมากเขียนโดยผู้เชี่ยวชาญ มีความเสถียรเพียงใด เป็นต้น ฉันเพียงแค่ศึกษามันอย่างละเอียด และหนึ่งในคำแนะนำที่พวกเขาให้ฉันก็คือ ในการส่งข้อความระหว่างเธรด ก็เพียงพอแล้วที่จะใช้ BlockingQueue ซึ่งถูกห่อหุ้มด้วยภาษาจาวา

เพียงพอแล้ว มาเขียนโค้ดเพื่อทดสอบกันดีกว่า

คัดลอกรหัสรหัส ดังต่อไปนี้:

//แพ็คเกจเริ่มต้น
นำเข้า java.util.concurrent.*;

ฐานการนำเข้า MyRunnable;

การทดสอบในชั้นเรียนสาธารณะ
-
โมฆะสาธารณะคง main (String [] args)
-
BlockingQueue<Integer> คิว = ใหม่ LinkedBlockingQueue<Integer>();
java.lang.Runnable r = MyRunnable ใหม่ (คิว);
เธรด t = เธรดใหม่ (r);
t.เริ่มต้น();

ในขณะที่(จริง)
-
พยายาม
-
ในขณะที่(จริง)
-
สำหรับ(int i =0;i < 10,000;i++)
-
คิวข้อเสนอ (i);
-
-
-
จับ (ยกเว้น e)
-
e.printStackTrace();
-
-
-
-


//แพ็คเกจที่ต้องเพิ่ม
ฐานบรรจุภัณฑ์

นำเข้า java.lang.Runnable;
นำเข้า java.util.concurrent.*;
นำเข้า java.util.*;

MyRunnable คลาสสาธารณะใช้งาน Runnable
-
MyRunnable สาธารณะ (คิว BlockingQueue <Integer>)
-
this.queue = คิว;
-
การรันโมฆะสาธารณะ ()
-
วันที่ d = วันที่ใหม่ ();
เวลาเริ่มต้นนาน = d.getTime();
System.err.println (เวลาเริ่มต้น);
นับจำนวน = 0;
ในขณะที่(จริง)
-
พยายาม
-
จำนวนเต็ม i = this.queue.poll();
ถ้า(i != null)
-
นับ++;
-
ถ้า (นับ == 100,000)
-
วันที่ e = วันที่ใหม่ ();
เวลาสิ้นสุดที่ยาวนาน = e.getTime();
System.err.println(นับ);
System.err.println (เวลาสิ้นสุด);
System.err.print (เวลาสิ้นสุด - เวลาเริ่มต้น);
หยุดพัก;
-

-
จับ (ยกเว้น e)
-

-
-
-
คิว BlockingQueue <Integer> ส่วนตัว;
-


ในการถ่ายโอนข้อมูล 100,000 ชิ้น เครื่องทดสอบของฉันจะใช้เวลาประมาณ 50 มิลลิวินาที ซึ่งก็ไม่เลวเลย! เพียงดูที่การใช้งานพื้นฐานของ BlockingQueue

ฉันใช้ข้อเสนอและการสำรวจความคิดเห็นในโค้ดทดสอบด้านบน มาดูฟังก์ชันการใช้งานทั้งสองนี้กัน

คัดลอกรหัสรหัส ดังต่อไปนี้:

โพล E สาธารณะ () {
จำนวน AtomicInteger สุดท้าย = this.count;
ถ้า (count.get() == 0)
กลับเป็นโมฆะ;
อี x = โมฆะ;
อินท์ค = -1;
ReentrantLock สุดท้าย takeLock = this.takeLock;
takeLock.ล็อค();
พยายาม {
ถ้า (count.get() > 0) {
x = แยก ();
c = count.getAndDecreation();
ถ้า (ค > 1)
notEmpty.signal();
-
} ในที่สุด {
takeLock.ปลดล็อค();
-
ถ้า (c == ความจุ)
สัญญาณไม่เต็ม();
กลับ x;
-

มันคล้ายกับเธรดการซิงโครไนซ์ทั่วไป ยกเว้นว่ามีการเพิ่มสัญญาณอีกหนึ่งสัญญาณ เมื่อเรียนรู้การเขียนโปรแกรมขั้นสูงในสภาพแวดล้อม Unix ฉันเห็นว่าตัวแปรเงื่อนไขถูกใช้สำหรับการซิงโครไนซ์ระหว่างเธรด และเธรดสามารถซิงโครไนซ์ในลักษณะการแข่งขันได้!
การใช้งานฟังก์ชั่นการสำรวจความคิดเห็นก็คล้ายกัน!
คัดลอกรหัสรหัส ดังต่อไปนี้:

ข้อเสนอบูลีนสาธารณะ (E e) {
ถ้า (e == null) โยน NullPointerException ใหม่ ();
จำนวน AtomicInteger สุดท้าย = this.count;
ถ้า (count.get() == ความจุ)
กลับเท็จ;
อินท์ค = -1;
ReentrantLock สุดท้าย putLock = this.putLock;
putLock.ล็อค();
พยายาม {
ถ้า (count.get() <ความจุ) {
แทรก(อี);
c = count.getAndIncreation();
ถ้า (c + 1 <ความจุ)
notFull.signal();
-
} ในที่สุด {
putLock.unlock();
-
ถ้า(ค==0)
signalNotEmpty();
กลับค >= 0;
-

บทความที่เกี่ยวข้อง