คำอธิบายโดยละเอียดเกี่ยวกับการใช้การซิงโครไนซ์แบบมัลติเธรดตามการตรวจสอบ Java

การรันโมฆะสาธารณะ ()
-
System.out.println(Thread.currentThread().getName() + " เริ่ม");
สำหรับ (int i = 1; i <= 100; i++)
-
ผลรวม += ฉัน;
-
พยายาม {
เธรด.สลีป(500);
} จับ (InterruptedException e) {
e.printStackTrace();
-
System.out.println(Thread.currentThread().getName() + " --- ค่าของผลรวมคือ " + ผลรวม);
System.out.println(Thread.currentThread().getName() + " สิ้นสุด");
-
-

โมฆะคงที่ส่วนตัว sharedVaribleTest() พ่น InterruptedException
-
MyRunner runner = MyRunner ใหม่();
เธรด thread1 = เธรดใหม่ (รองชนะเลิศ);
เธรด thread2 = เธรดใหม่ (รองชนะเลิศ);
thread1.setDaemon(จริง);
thread2.setDaemon(จริง);
thread1.start();
thread2.start();
thread1.join();
thread2.เข้าร่วม();
-

โมฆะคงที่ส่วนตัว syncTest() พ่น InterruptedException
-
MyNonSyncRunner runner = MyNonSyncRunner ใหม่ ();
เธรด thread1 = เธรดใหม่ (รองชนะเลิศ);
เธรด thread2 = เธรดใหม่ (รองชนะเลิศ);
thread1.setDaemon(จริง);
thread2.setDaemon(จริง);
thread1.start();
thread2.start();
thread1.join();
thread2.เข้าร่วม();
-

โมฆะคงที่ส่วนตัว sharedVaribleTest3() พ่น InterruptedException
-
MyRunner2 runner = MyRunner2(); ใหม่
เธรด thread1 = เธรดใหม่ (รองชนะเลิศ);
เธรด thread2 = เธรดใหม่ (รองชนะเลิศ);
thread1.setDaemon(จริง);
thread2.setDaemon(จริง);
thread1.start();
thread2.start();
thread1.join();
thread2.เข้าร่วม();
-

การรันโมฆะสาธารณะ ()
-
System.out.println(Thread.currentThread().getName() + " เริ่ม");
สำหรับ (int i = 0; i <= 100; i++)
-
ถ้า (tl.get() == null)
-
tl.set(จำนวนเต็มใหม่(0));
-
int sum = ((จำนวนเต็ม)tl.get()).intValue();
ผลรวม+= ฉัน;
tl.set(จำนวนเต็มใหม่(ผลรวม));
พยายาม {
เธรด.สลีป(10);
} จับ (InterruptedException e) {
e.printStackTrace();
-
-

System.out.println(Thread.currentThread().getName() + " --- ค่าของผลรวมคือ " + ((Integer)tl.get()).intValue());
System.out.println(Thread.currentThread().getName() + " สิ้นสุด");
-
-

โมฆะคงที่ส่วนตัว sharedVaribleTest4() พ่น InterruptedException
-
MyRunner3 runner = MyRunner3(); ใหม่
เธรด thread1 = เธรดใหม่ (รองชนะเลิศ);
เธรด thread2 = เธรดใหม่ (รองชนะเลิศ);
thread1.setDaemon(จริง);
thread2.setDaemon(จริง);
thread1.start();
thread2.start();
thread1.join();
thread2.เข้าร่วม();
-

โมฆะคงที่ส่วนตัว syncTest2 () พ่น InterruptedException
-
MySyncRunner runner = MySyncRunner ใหม่ ();
เธรด thread1 = เธรดใหม่ (รองชนะเลิศ);
เธรด thread2 = เธรดใหม่ (รองชนะเลิศ);
thread1.setDaemon(จริง);
thread2.setDaemon(จริง);
thread1.start();
thread2.start();
thread1.join();
thread2.เข้าร่วม();
-

เธรด thread1 = เธรดใหม่ ()
-
การรันโมฆะสาธารณะ ()
-
System.out.println(Thread.currentThread().getName() + " เริ่ม");
สุ่ม r = สุ่มใหม่ (100);
ซิงโครไนซ์ (รายการ)
-
สำหรับ (int i = 0; i < 5; i++)
-
list.add(จำนวนเต็มใหม่(r.nextInt()));
-
System.out.println("ขนาดของรายการคือ" + list.size());
-
พยายาม
-
เธรด.สลีป(500);
-
จับ (InterruptedException เช่น)
-
เช่น printStackTrace();
-
System.out.println(Thread.currentThread().getName() + " สิ้นสุด");
-
-

เธรด thread2 = เธรดใหม่ ()
-
การรันโมฆะสาธารณะ ()
-
System.out.println(Thread.currentThread().getName() + " เริ่ม");
สุ่ม r = สุ่มใหม่ (100);
ซิงโครไนซ์ (รายการ)
-
สำหรับ (int i = 0; i < 5; i++)
-
list.add(จำนวนเต็มใหม่(r.nextInt()));
-
System.out.println("ขนาดของรายการคือ" + list.size());
-
พยายาม
-
เธรด.สลีป(500);
-
จับ (InterruptedException เช่น)
-
เช่น printStackTrace();
-
System.out.println(Thread.currentThread().getName() + " สิ้นสุด");
-
-

thread1.start();
thread2.start();
thread1.join();
thread2.เข้าร่วม();
-

แจกแจง ThreadTask
-
เริ่ม,
หยุด,
นอน,
ตื่น
-

คลาส MyThread ขยายเธรด
-
สถานะ ThreadStatus สาธารณะ = ThreadStatus.Initial;
งาน ThreadTask สาธารณะ
การรันโมฆะสาธารณะ ()
-
สถานะ = ThreadStatus.Running;
ในขณะที่(จริง)
-
พยายาม {
เธรด.สลีป(3000);
ถ้า (สถานะ == ThreadStatus.Sleeping)
-
System.out.println(Thread.currentThread().getName() + "เข้าสู่สถานะสลีป");
นี้.รอ();
-
} จับ (InterruptedException e) {
System.out.println(Thread.currentThread().getName() + "เกิดข้อผิดพลาดระหว่างการดำเนินการ");
status = ThreadStatus.Stopped;
-
-
-
-

โมฆะสาธารณะคงที่ ManageThread (เธรด MyThread งาน ThreadTask)
-
ถ้า (งาน == ThreadTask.Start)
-
ถ้า (thread.status == ThreadStatus.Running)
-
กลับ;
-
ถ้า (thread.status == ThreadStatus.Stopped)
-
เธรด = MyThread ใหม่ ();
-
thread.status = ThreadStatus.Running;
เธรด.เริ่มต้น();

-
อย่างอื่นถ้า (งาน == ThreadTask.Stop)
-
ถ้า (thread.status != ThreadStatus.Stopped)
-
เธรด.ขัดจังหวะ();
thread.status = ThreadStatus.หยุด;
-
-
อย่างอื่นถ้า (งาน == ThreadTask.Sleep)
-
thread.status = ThreadStatus.Sleeping;
-
อย่างอื่นถ้า (งาน == ThreadTask.Wakeup)
-
thread.notify();
thread.status = ThreadStatus.Running;
-
-

สาธารณะสตริงคงที่ getThreadStatus (เธรด MyThread [])
-
StringBuffer sb = StringBuffer ใหม่ ();
สำหรับ (int i = 0; i < threads.length; i++)
-
sb.append(threads[i].getName() + "สถานะ: " + threads[i].status).append("/r/n");
-
กลับ sb.toString();
-
-

โมฆะคงที่สาธารณะ main (String [] args) พ่น IOException
-
MyThreadPool พูล = MyThreadPool ใหม่ (5);
-

เธรด int ส่วนตัว;
เธรด MyThread[] ส่วนตัว = null;

MyThreadPool สาธารณะ (จำนวน int) พ่น IOException
-
this.threadCount = นับ;
เธรด = MyThread ใหม่ [นับ];
สำหรับ (int i = 0; i < threads.length; i++)
-
เธรด [i] = MyThread ใหม่ ();
กระทู้[i].เริ่มต้น();
-
เริ่มต้น();
-

โมฆะส่วนตัว Init() พ่น IOException
-
ServerSocket serverSocket = ServerSocket ใหม่ (5678);
ในขณะที่(จริง)
-
ซ็อกเก็ตซ็อกเก็ตสุดท้าย = serverSocket.accept ();
เธรดเธรด = เธรดใหม่ ()
-
การรันโมฆะสาธารณะ ()
-
พยายาม
-
System.out.println("ตรวจพบการเชื่อมต่อซ็อกเก็ตใหม่");
BufferedReader br = BufferedReader ใหม่ (InputStreamReader ใหม่ (socket.getInputStream()));
PrintStream ps = PrintStream ใหม่ (socket.getOutputStream());
เส้นสตริง = null;
ในขณะที่ ((line = br.readLine()) != null)
-
System.out.println (บรรทัด);
ถ้า (line.equals("นับ"))
-
System.out.println("มี 5 เธรดในเธรดพูล");
-
อย่างอื่นถ้า (line.equals("Status"))
-
สถานะสตริง = MyThreadManager.getThreadStatus(threads);
System.out.println (สถานะ);
-
อย่างอื่นถ้า (line.equals("StartAll"))
-
MyThreadManager.manageThread (เธรด, ThreadTask.Start);
-
อย่างอื่นถ้า (line.equals("StopAll"))
-
MyThreadManager.manageThread (เธรด, ThreadTask.Stop);
-
อย่างอื่นถ้า (line.equals("SleepAll"))
-
MyThreadManager.manageThread (เธรด, ThreadTask.Sleep);
-
อย่างอื่นถ้า (line.equals("WakeupAll"))
-
MyThreadManager.manageThread (เธรด, ThreadTask.Wakeup);
-
อย่างอื่นถ้า (line.equals("End"))
-
หยุดพัก;
-
อื่น
-
System.out.println("คำสั่ง:" + บรรทัด);
-
PS.println("ตกลง");
PS.ฟลัช();
-
-
จับ (ข้อยกเว้นเช่น)
-
เช่น printStackTrace();
-
-
-
เธรด.เริ่มต้น();
-
-
-

MyRunner runner = MyRunner ใหม่();

ScheduledFuture สุดท้าย<?> handler1 = scheduler.scheduleAtFixedRate (รองชนะเลิศ, 1, 10, TimeUnit.SECONDS);
ScheduledFuture สุดท้าย <?> handler2 = scheduler.scheduleWithFixedDelay (นักวิ่ง, 2, 10, TimeUnit.SECONDS);

scheduler.schedule (รันใหม่ ()
-
การรันโมฆะสาธารณะ ()
-
handler1.cancel (จริง);
handler2.cancel (จริง);
กำหนดการปิดเครื่อง();
-
}, 30, หน่วยเวลา วินาที
-
-

เธรด.สลีป(1,000);
สำหรับ(int i = 0; i < 10; i++)
-
ผลลัพธ์ในอนาคต <String> = service.take();
System.out.println("ค่าที่ส่งคืนของเธรดคือ" + result.get());
-
ดำเนินการปิดเครื่อง();
-

โมฆะสาธารณะคง main (String [] args)
-
การปิดกั้น QueueTest();
-

โมฆะคงที่ส่วนตัว blockingQueueTest ()
-
สุดท้าย BlockingQueue<Integer> คิว = ใหม่ LinkedBlockingQueue<Integer>();
int สุดท้าย maxSleepTimeForSetter = 10;
int สุดท้าย maxSleepTimerForGetter = 10;

ตัวตั้งค่า Runnable = Runnable ใหม่ ()
-
การรันโมฆะสาธารณะ ()
-
สุ่ม r = สุ่มใหม่ ();
ในขณะที่(จริง)
-
ค่า int = r.nextInt(100);
พยายาม
-
Queue.put(จำนวนเต็มใหม่(ค่า));
System.out.println(Thread.currentThread().getName() + "---ใส่ค่าลงในคิว" + ค่า);
Thread.sleep(r.nextInt(maxSleepTimeForSetter) * 1,000);
-
จับ (ข้อยกเว้นเช่น)
-
เช่น printStackTrace();
-
-
-
-

Runnable getter = Runnable ใหม่ ()
-
การรันโมฆะสาธารณะ ()
-
สุ่ม r = สุ่มใหม่ ();
ในขณะที่(จริง)
-
พยายาม
-
ถ้า (queue.size() == 0)
-
System.out.println(Thread.currentThread().getName() + "---คิวว่างเปล่า");
-
อื่น
-
ค่า int = Queue.take().intValue();
System.out.println(Thread.currentThread().getName() + "---รับค่าจากคิว" + ค่า);
-
Thread.sleep(r.nextInt(maxSleepTimerForGetter) * 1,000);
-
จับ (ข้อยกเว้นเช่น)
-
เช่น printStackTrace();
-
-
-
-

ExecutorService exec = Executors.newFixedThreadPool(2);
exec.execute (ตัวตั้งค่า);
exec.execute (ทะเยอทะยาน);
-
-

สำหรับ (int i = 0; i < 10; i++)
-
Runnable runner = Runnable ใหม่ ()
-
การรันโมฆะสาธารณะ ()
-
พยายาม
-
semp.ได้รับ();
System.out.println(วันที่ใหม่() + " " + Thread.currentThread().getName() + "กำลังดำเนินการ");
เธรด.สลีป(5000);
semp.ปล่อย();
-
จับ (ข้อยกเว้นเช่น)
-
เช่น printStackTrace();
-
-
-
exec.execute (รองชนะเลิศ);
-

ดำเนินการปิดเครื่อง();
-

โมฆะสาธารณะวิ่ง () {
สุ่ม r = สุ่มใหม่ ();
พยายาม
-
สำหรับ (int i = 0; i < 3; i++)
-
Thread.sleep(r.nextInt(10) * 1,000);
System.out.println(วันที่ใหม่() + "--" + Thread.currentThread().getName() + "--th" + (i + 1) + "รอ");
สิ่งกีดขวาง.รอ();
-
-
จับ (ข้อยกเว้นเช่น)
-
เช่น printStackTrace();
-
-

-

โมฆะคงที่ส่วนตัว cyclicBarrierTest ()
-
สิ่งกีดขวาง CyclicBarrier = CyclicBarrier ใหม่ (3);

ExecutorService exec = Executors.newFixedThreadPool(3);
สำหรับ (int i = 0; i < 3; i++)
-
exec.execute (MyRunner2 ใหม่ (อุปสรรค));
-
ดำเนินการปิดเครื่อง();
-