知识大全多线程的批量线程同步解决方案

Posted 2022-07-18 知

篇首语：日日行，不怕千万里；时时学，不怕千万卷。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全多线程的批量线程同步解决方案相关的知识，希望对你有一定的参考价值。

　　多线程运行时有待处理线程？试试看下面介绍的这个批量线程同步方法吧

　　在一批线程处理程序中有时必须等到所有线程全部运行完后才能进行下一步任务处理可以采用如下方法解决创建一个锁对象该锁对象提供一个当前线程等待其他线程的方法见代码

　　 /**

　　 * 此类主要用来处理线程的同步屏蔽模型比如一批线程运行必须在最后一个线程运行

　　 * 完后才能进行下一步的操作那么就可以创建一个锁对象锁对象提供一个线程等待其他线程

　　 * 的方法如果当前线程运行时还有未运行的线程则此线程wait 否则此线程唤醒其他阻塞的

　　 * 线程进而最终完成线程的运行

　　 * */

　　 public class LockObject

　　 private int totalThread = ;

　　 private int currentThread = ;

　　 public LockObject(int totalThread)

　　 this totalThread = totalThread;

　　 this currentThread = ;

　　 public synchronized void waitForOtherThread()

　　 if (this currentThread < this totalThread)

　　 this currentThread++;

　　 try

　　 this wait();

　　 catch (InterruptedException e)

　　 // TODO Auto generated catch block

　　 e printStackTrace();

　　 else

　　 this currentThread = ;

　　 notifyAll();

　　 public int getTotalThread()

　　 return totalThread;

　　 public void setTotalThread(int totalThread)

　　 this totalThread = totalThread;

　　 public int getCurrentThread()

　　 return currentThread;

　　 public void setCurrentThread(int currentThread)

　　 this currentThread = currentThread;

　　批量线程同步机制介绍

　　此对象提供二个私有变量 totalThread 的初始值为所运行的线程的总数 currentThread 为当前正在运行的线程数

　　线程运行时处理完自己的任务后调用方法waitForOtherThread 等待其他线程结束即当前运行线程数与线程总数的比较

　　如果运行线程数小于线程总数则当前运行线程数+ 后当前线程进入等待状态否则唤醒其他等待线程

　　见测试程序

　　 public class MyThread extends Thread

　　 public static LockObject lo = new LockObject( );

　　 public MyThread(String threadName)

　　 super(threadName);

　　 public void run()

　　 System out println(Thread currentThread() getName() + 开始运行 );

　　 lo waitForOtherThread();

　　 System out println(Thread currentThread() getName() + 结束运行 );

　　 public static void main(String[] args)

　　 for (int i = ; i <= ; i++)

　　 Thread thread = new MyThread( 第 + i + 个线程 );

　　 thread setPriority(NORM_PRIORITY);

　　 thread start();

cha138/Article/program/Java/gj/201311/27516

知识大全 多线程的批量线程同步解决方案

知识大全多线程的批量线程同步解决方案