最近做的程序出现了一个多线程的问题,肯定是同步引起的,但是我个人还是不太理解,因为同样一段代码在Windows下运行正常,在Linux下就处理一堆问题了。
程序思想是这样子的,有多个任务需要处理,每次主线程处理一个任务,并把这个任务分成多个子任务让子线程去处理。在主线程中启动多个子线程去做事情,并注册自己。主线程就不断的检查是所有线程已经注销了,子线程做完事情后,会向主线程销自己,然后结束。
代码如下:
public class TaskDispatchController
{
Set threadSet = new HashSet();
/**
* 启动子线线程做事情
*/
private void startThread()
{
//重用线程对象
ImportThread[] thread = importTool.getImportThread();
threadList = new ArrayList(thread.length);
for (int i = 0; i < thread.length; i++)
{
ImportThread impThread = thread[i];
//子线程注册自己
threadSet.add(impThread);
impThread.setController(this);
new Thread(impThread).start();
}
checkQuite();
}
/**
* 注销自己,并唤醒主线程检查是否可以退出
*/
public synchronized void unregister(ImportThread thread)
{
threadSet.remove(thread);
notifyAll();
}
/**
*
*/
private synchronized void checkQuite()
{
try
{
while (!threadSet.isEmpty())
{
wait();
}
backThread();
}
catch (InterruptedException e)
{
throw new ThreadOperationException("main thread exception", e);
}
finally
{
close();
}
}
}
public class ImportThread
{
TaskDispatchController taskDispatchController = null;
public void setController(TaskDispatchController taskDispatchController )
{
this.taskDispatchController = taskDispatchController ;
}
public void run()
{
if (taskDispatchController == null)
{
return;
}
//做某事情
[b]taskDispatchController.doXXX();[/b]
while (true)
{
// do something
}
//执行完事情后结束
release();
}
private void release()
{
if (taskDispatchController != null)
{
taskDispatchController .unregister(this);
}
[b]taskDispatchController == null;[/b]
}
}
这段代码在Windows下,双核CPU的环境中做事不会出现错误,且可以启动多个子线程。但在Linux环境下,就启动一个子线程就会出问题,会出现死锁,并且是销在TaskDispatchController的startThread方法,感到很奇怪。
解决方法:随后,我将startThread线程,并标记为同步,并且要所有子线程启动后,子线程才能注销自己。以避免子线程跑得太快了,就结束自己了(这是领导认为的问题所在,但我个人不这么认为,看代码就明白了)。
修改了之后仍然出现死锁。原因是:在子线程run中调用taskDispatchController.doXXX()的时候报NullPointerException,导致子线程没有注销自己,主线程处于一直等待状态。
解决方法:因为我在线程结束的时候将taskDispatchController = null了(也不知道当时是怎么考虑的,其实没有必要设置为null),所以我将release方法中这一行删去。
并修改TaskDispatchController.unregister方法
public synchronized void unregister(ImportThread thread)
{
threadSet.remove(thread);
thread.setController(null);
notifyAll();
}
现在程序在Linux下能正常运行,但其中的原因还是不得而知,希望哪位指点指点
分享到:
相关推荐
Linux多线程Linux多线程Linux多线程Linux多线程Linux多线程Linux多线程Linux多线程
linux多线程编程.pdf
linux下多线程编程linux下多线程编程linux下多线程编程linux下多线程编程linux下多线程编程
Linux多线程服务端编程,高清无水印!~
Linux系统下的多线程编程入门.pdf Linux系统下的多线程编程入门.pdf Linux系统下的多线程编程入门.pdf Linux系统下的多线程编程入门.pdf Linux系统下的多线程编程入门.pdf Linux系统下的多线程编程入门.pdf Linux...
Linux下的多线程编程.pdf
linux下多线程是想操作系统的经典生产者和消费者模拟实验。用C语言编写,gcc能够编译。而且含有makefile文件的解释。
linux下多线程实现矩阵乘法,可以对操作系统的线程有更多理解
Linux多线程服务端编程 Linux多线程服务端编程 Linux多线程服务端编程 Linux多线程服务端编程 Linux多线程服务端编程
linux多线程教程.zip
本文我们将介绍在Linux 下编写多进程和多线程程序的一些初步知识。 1 引言 对于没有接触过 Unix/Linux 操作系统的人来说,fork 是最难理解的概念之一:它执行 一次却返回两个值。fork 函数是Unix 系统最杰出的成就之...
本书主要讲述采用现代C++ 在x86-64 Linux 上编写多线程TCP 网络服务程序的主流常规技术,重点讲解一种适应性较强的多线程服务器的编程模型,即one loop per thread。这是在Linux 下以native 语言编写用户态高性能...
《Linux多线程服务端编程:使用muduo C++网络库》主要讲述采用现代C++在x86-64 Linux上编写多线程TCP网络服务程序的主流常规技术,重点讲解一种适应性较强的多线程服务器的编程模型,即one loop per thread。这是在...
Linux 多线程编程笔记——简单、好记、好用说明:本代码参考麦子学院魏杰老师的Linux多线程编程 视频教程,整理有参考网上的做出修改,自己也可以参考网上比较好的例程
linux 系统的编程的源码,对初学者很有帮助。多线程、内存、信号量等程序。
线程如何去创建 ,多线程如何控制输出!互斥控制!
基于6410的linux下多线程源码。很简单,方便移植