Qt等待多个子线程结束后主线程继续执行的问题_course

我开了一个线程，然后在这个线程中开了多个子线程，当每个子线程运行完后都会发送finished信号，变量cnt+1，统计子线程完成的个数，父线程有一个while循环，但cnt大于等于子线程个数时就跳出循

linux多线程编程中如何等待过个线程退出_course

linux多线程编程中，如果线程A创建了线程B，我知道用pthread__ join可以令线程A 阻塞然后等待线程B的退出。如果线程A创建了三个线程B,C,D，执行完的先后顺序不知。想让A必须等待三个线程都退出后再退出，应该怎么做？ 连用pthread__join三次吗？？？但是第一次用了pthread__join后，A不就阻塞了吗？

Java中线程的join()方法，为什么是主线程等待，而不是调用join()方法的线程等待？_course

``` public class ThreadMethods { public static void main(String[] args) { //继承Runnable Runnable r = new Runnable() { public void run() { System.out.println(Thread.currentThread().getName()+"执行完毕！"); } }; //创建线程对象 Thread t1 = new Thread(r,"t1"); //启动线程 t1.start(); try { /*中断主线程，让t1线程先执行。 *我疑惑的就是这里，是t1对象调用的join()方法，进入join()方法源码中，有一段代码： *if (millis == 0) { while (isAlive()) { wait(0); } } * 这里判断isalive(),等价于t1.isAlive(),结果为true,然后调用t1.wait(0)方法, * 既然是t1调用的wait(0)方法，不是应该让t1等待吗？为什么结果是主线程（mian）等待呢？ * */ t1.join(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("主线程执行完毕！"); } } ``` 结果： t1执行完毕！ 主线程执行完毕！

windows主线程如何等待子线程结束_course

我在主线程中起了多个子线程，想等所有子线程结束主线程再继续做后面的事情。 但是我自起子线程的函数下面用WaitForMultipleObjects等待所有子线程结束，会阻塞主线程导致程序无反应死掉。 请各位大侠帮忙看下应该如何处理？

delphi xe中同时等待几个匿名线程,运行时结果错误(没cb了,无法悬赏)_course

我原本是想创建几个线程,同时写如数字在memo中.然后用waitformultipleobjects等待 全部线程全部完成后写入ok.可问题是运行后结果错误如下. (搞到了2cb,如何添加?) 1:等待不到结束线程.超时3秒过后写入ok.然后再写入数字. 2:原本我想写的应该是0-5的数字,可运行后基本是写入6最多. 代码如下.我该如何改?没cb了.请各位不吝赐教. var Testthread: TThread; Waitthread: TWOHandleArray; i: integer; begin memo1.Clear; for i := 0 to 5 do begin Testthread:= TThread.CreateAnonymousThread( procedure var k: integer; begin k:= i; memo1.Lines.Add(IntToStr(k)); end); Waitthread[i]:= Testthread.Handle; // Testthread.FreeOnTerminate:= True; Testthread.Start; end; WaitForMultipleObjects(6, @Waitthread, false,3000 );{INFINITE} memo1.Lines.Add('ok'); end;

c++ 11 在局部使用async()创建一个线程，当程序运行出局部区域时，为什么代码会阻塞等待线程执行结束？_course

1. 在局部使用async()创建一个线程，当程序退出局部区域时，代码阻塞等待线程执行结束 类似下面的代码：必须等待“hi”输出，才能输出“hello world” ``` int main() { { std::async(std::launch::async, [](){ sleep(10); cout << "hi" << endl; return 8; }); } std::cout << "Hello, World!" << std::endl; cin.ignore(); return 0; } ```

JDBC一个connection下多线程查询表数据会产生线程等待_course

案例： 从Oracle数据库将表及数据通过JDBC的方式采集到另一Oracle数据库，数据量均为千万级，从源数据库读取的时候采用ORACLE的ROWNUM分页方式，JDBC每次读取1000条，批量插入目标库，测试发现ORACLE的ROWNUM分页效率很是问题，越到后面越慢，WEBLOGIC后台甚至出现线程请求超时。 后来采用多线程的方式，创建一个连接，后台起100个线程，测试发现跟单线程的效率差不了多少，分析代码后，线程在创建preparedStatement时会产生等待，是不是创建preparedStatement时资源会互斥？搞不明白。 示例代码： ... ExecutorService threadPool = Executor.newFixedThreadPool(100); Futrue futrue = null; for(int i=0; i<=recordNum/1000;) { for(int j=0; j<100; j++) { final int m = i; futrue = threadPool.submit( new Callable() { Object[][] o = null; public void call() { //就是下面这句多线程下查询执行时间越往后越慢 o = odsDB.executeBatchQuery(tableName, MAX_BATCH_NUM*m, MAX_BATCH_NUM); if(o != null) { toDB.executeBatchInsert(insertSQL, o); toDB.commit(); } } }); i++; } } threadPool.shutdown(); while(true) { if(threadPool.Terminated()) { break; } Thread.sleep(2000); } ..... 被调用的odsDB.executeBatchQuery()方法 Object[][] o = null; PreparedStatement ps = null; ResultSet rs = null; String queryStr = null; try{ queryStr = "SELECT * FROM ( SELECT A.*, ROWNUM RN FROM " + tabName + " A WHERE ROWNUM <=? ) WHERE RN > ?"; ps = this.conn.preparedStatement(queryStr); //100条多线程下此代码执行时长越来越长。 ps.setLong(1, count+offset); ps.setLong(2, count); rs = ps.executeQuery(); } catch(Exception e) { } //下面代码将rs转成Obejct[][]返回 求各路大侠帮忙这个问题要怎么解决。

主线程等待子线程运行结束再完成的效果如何实现_course

主线程抛出一个子线程异步处理一些东西，这时主线程要等待子线程运行完成再完成（其实我是为了统计运行时间的）。 这里抛出的子线程可能递归的调用自己，就是再抛一个他的子线程出来，但是到底一共抛多少，事先是不知道的。 应用场景： 1）多线程扫描文件夹内的文件，遇到文件夹内有子文件夹，要递归调用扫描线程的，等到全部扫描完成后，返回结果，显示； 2）多线程快速排序，第一次肯定是单线程的，第一次排序完成后，会分两半，这两半多线程排，递归调用了这个排序线程，这两半很有可能，极大有可能再各分两半，也就是会有4个子线程的子线程再排序。 我试过网上的那个 CountDownLatch ，但是他只能实现定义好子线程的数量，但是在以上两种情景下，事先你是不知道会有多少个子线程的！ c++里有个WaitForSingleObject，java里有么？

MongoDB多线程读取集合和单线程效率一样？_course

要读取MongoDB中的50W条数据，因为数据太多决定分批读取每次读取10000条，每次读取时间大概需要2s，循环50次大概是用50*2=100s； 由于化肥时间太长决定使用多线程，程序中并发了10个线程去查询， 本来以为值需要2*50/10=10s钟就可以完成，结果发现最终总时间还是用了100s 郁闷。。。。 查看日志的时候发现第一个线程用可2s，然后后面的4s 5s 8s 。。。。100s逐渐增多。 现象看来是线程读取出现了等待，mongo读取难道也是阻塞的吗，求大神指导

如何随时终止C++线程的运行？_course

需要用在工业控制方面。 由于几乎每一句代码都会控制外部设备的运动，所以为了使外部设备能够及时停止运动，操作时可能随时会终止线程的执行。 例如一个工作线程： t1(LPVOID lparam) { while( true ) { move(1); move(2); move(3); move(4); } return 0; } 当我单击停止按钮时，不论t1执行到4步中的哪一步，线程必须停止执行并退出而非等待线程完全执行完毕。停止的位置可能是第一步，可能是第二步...... 我尝试过用标识，单击按钮时将停止变量bStop置为TURE，然后在每一个动作执行完毕后检测bStop的状态。但是这样很麻烦，这意味着几乎每一行代码后都要检测bStop的状态。 想请问有经验的朋友们，除此之外，有没有什么方法可以直接在外部（按钮事件或其他线程中）终止线程？

C#异步线程回调问题，请大神帮忙_course

问大神一个关于异步线程回调的问题 程序运行后执行主线程的第一次循环，执行到代码A后，调用线程B异步执行 主线程继续执行 主线程第一次循环执行完后，执行第二次循环， 然后执行到代码A后 判断B线程的执行状态，如果B线程没有完成，则主线程等待B线程执行完成后再继续向下执行 以此反复 我这边写了B线程回调函数中将判断条件设为true,然后在B线程前面对这个条件进行了判断，发现没有用 不知道怎么回事儿 大神帮忙看下怎么做才能实现我想要的效果

javaGC回收时，sleep状态并不在安全区域的线程怎么办？还是说线程中断时肯定在安全区域？_course

深入理解java虚拟机中74,75页讲到安全区域，说到了线程在安全区域的情况，发生GC时，不用管在安全区域的线程，那不在安全区域的线程是什么情况？还是线程中断时，都会停留在安全区域？能提供一下参考资料么 安全区域描述如下 这里忽略了一个问题，当发生GC时，运行中的线程可以跑到Safe Point后进行挂起，而那些处于Sleep或Blocked状态的线程在此时无法响应JVM的中断请求，无法到Safe Point处进行挂起，针对这种情况，可以使用安全区域（Safe Region）进行解决。 Safe Region是指在一段代码片段中，对象的引用关系不会发生变化，在这个区域中的任何位置开始GC都是安全的。 1、当线程运行到Safe Region的代码时，首先标识已经进入了Safe Region，如果这段时间内发生GC，JVM会忽略标识为Safe Region状态的线程； 2、当线程即将离开Safe Region时，会检查JVM是否已经完成GC，如果完成了，则继续运行，否则线程必须等待直到收到可以安全离开Safe Region的信号为止；

linux 下c 程序，开了1024个线程 依次等待共同完成某个任务，程序异常退出，不出core_course

程序简单来说类似一个多线程下载器，开了1024个线程，然后并发去服务器读取一个大文件的某一块，读取完成后，文件合并要按照顺序写文件，所以我采用了pthread_join依次等待上一个线程写完成操作。测试时候发现程序偶尔会突然down掉，也不出core，并不是总down，也会有成功执行时候。机器配制足够高了，内存96G，24核cpu。。。希望大家帮忙分析下。。谢谢，代码逻辑如下。 void* thread_fun() { ...... if(id != 0)pthread_join(thread_list[id - 1],NULL);//等待上一个线程结束 write(fd,th_d->file,file - th_d->file);//写文件 }

关于pthread_mutex多个线程忙等待问题？_course

文档说如果对一个已加锁的mutex再次加锁pthread_mutex_lock会形成一个等待队列。可是这个示例有点奇怪，我知道线程没有放弃cpu，可是为什么后面输出的hello不到数量？ ``` #ifndef THREAD_POOL_H #define THREAD_POOL_H #include <pthread.h> #include <errno.h> #include <iostream> #include <unistd.h> #include <queue> class sample { public: void process(); }; template <typename T> class threadPool { public: threadPool(); void append(T &s); static void *worker(void *s); private: std::queue<T *> tasks; pthread_t threads[5]; bool run = true; pthread_mutex_t t; }; // template <typename T> // void threadPool<T>::append(T& s) // { // pthread_t t; // pthread_create(&t,nullptr,worker,&s); // pthread_detach(t); // } template <typename T> threadPool<T>::threadPool() : tasks() { pthread_mutex_init(&t,nullptr); for(int i=0;i<5;++i) { pthread_create(&threads[i],nullptr,worker,this); pthread_detach(threads[i]); } } template <typename T> void threadPool<T>::append(T &s) { pthread_mutex_lock(&t); tasks.push(&s); printf("%d append.\n",pthread_self()); pthread_mutex_unlock(&t); } template <typename T> void *threadPool<T>::worker(void *s) { auto pool=static_cast<threadPool<T>*>(s); while (pool->run) { pthread_mutex_lock(&(pool->t)); if (pool->tasks.empty()) { pthread_mutex_unlock(&(pool->t)); printf("%d get the lock but continue.\n",pthread_self()); continue; } auto work = pool->tasks.front(); pool->tasks.pop(); printf("%d get the lock and print\n",pthread_self()); pthread_mutex_unlock(&(pool->t)); work->process(); } return nullptr; } #endif //!THREAD_POOL_H ``` ``` #include "thread_pool.h" void sample::process() { std::cout<<"hello world.\n"<<std::endl; } ``` ``` #include "thread_pool.h" #include <iostream> int main(int argc, char **argv) { threadPool<sample> pool; sample d[100]; for(int i=0;i<100;++i) { pool.append(d[i]); } return 0; } ``` ``` 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1268307712 get the lock but continue. 1285158720 append. 1268307712 get the lock and print 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1243129600 get the lock but continue. 1259915008 get the lock but continue. 1251522304 get the lock but continue. hello world. 1285158720 append. 1268307712 get the lock and print hello world. 1268307712 get the lock but continue. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1251522304 get the lock and print hello world. 1251522304 get the lock and print hello world. 1259915008 get the lock and print 1243129600 get the lock and print hello world. 1243129600 get the lock and print hello world. 1243129600 get the lock and print hello world. 1243129600 get the lock and print hello world. 1243129600 get the lock and print hello world. 1285158720 append. 1251522304 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1285158720 append. 1234736896 get the lock and print hello world. 1259915008 get the lock and print hello world. 1259915008 get the lock and print hello world. 1259915008 get the lock and print hello world. hello world. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1251522304 get the lock and print hello world. 1251522304 get the lock and print hello world. 1251522304 get the lock and print hello world. 1251522304 get the lock and print hello world. 1251522304 get the lock and print hello world. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1251522304 get the lock but continue. 1268307712 get the lock but continue. 1259915008 get the lock but continue. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1234736896 get the lock and print hello world. 1234736896 get the lock and print hello world. 1243129600 get the lock and print hello world. 1243129600 get the lock and print hello world. 1243129600 get the lock and print hello world. 1243129600 get the lock and print hello world. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1243129600 get the lock but continue. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. 1285158720 append. ``` **头晕了一下午，麻烦大佬出来解救众生。**

在android中把数据从一个线程发送到另一个线程_course

我在Android UI线程执行一些程序，有一个很耗时的程序，所以我把它放在另一个线程中。 1.在这个子线程运行后，UI线程会开始执行某个程序 2.这个程序将会在子线程中创建一些数据 这是我的解决方案： Car car; public void onResume(){ super.onResume(); Thread t = new Thread(){ car = new Car(); car.takePetrol; //take car full petrol } }); t.join(); count_How_far_Car_can_go(car.getPetrol); 我的代码中的问题是：我使用 t.join(); 等待线程结束，但这将会阻止UI线程。我创建了另外一个线程，就是想让UI线程可以顺利的执行。现在阻止UI线程，我不想在程序中出现这个现象。还有什么解决方法呢？

java多线程使用sleep后线程停止不再执行_course

环境：jdk1.7 程序代码： 启动线程： ``` import java.text.SimpleDateFormat; import java.util.Date; public class CTThread implements Runnable{ @Override public void run() { Thread upds = new Thread(new UpdateDSThread()); Thread uphs = new Thread(new UpdateHSThread()); uphs.setPriority(7); Thread dh = new Thread(new DeleteHistory()); Thread check = new Thread(new CheckStatus()); Thread cp = new Thread(new CheckPool()); // Thread sc = new Thread(new SCThread()); upds.start(); uphs.start(); dh.start(); check.start(); cp.start(); // sc.start(); SimpleDateFormat dd = new SimpleDateFormat("yyyy-MM-dd: HH:mm:ss"); while(true){ System.out.println("线程检查~~~·"+dd.format(new Date())); System.out.println("upds:"+upds.getState()+upds.getPriority()); System.out.println("check:"+check.getState()+check.getPriority()); System.out.println("uphs:"+uphs.getState()+uphs.getPriority()); System.out.println("dh:"+dh.getState()+dh.getPriority()); System.out.println("cp:"+cp.getState()+cp.getPriority()); // System.out.println("sc:"+sc.isAlive()+sc.getPriority()); if(!upds.isAlive()){ upds = new Thread(new UpdateDSThread()); upds.start(); } if(!check.isAlive()){ check = new Thread(new CheckStatus()); check.start(); } if(!uphs.isAlive()){ uphs = new Thread(new UpdateHSThread()); uphs.start(); } if(!dh.isAlive()){ dh = new Thread(new DeleteHistory()); dh.start(); } if(!cp.isAlive()){ cp = new Thread(new CheckPool()); cp.start(); } // if(!sc.isAlive()){ // sc = new Thread(new SCThread()); // sc.start(); // } try { Thread.sleep(1000*13); } catch (InterruptedException e) { e.printStackTrace(); } } } } ``` 线程1： ``` import entity.Device; import hibernate.Search; import main.UpdateDeviceStatus; import java.util.Iterator; import java.util.List; public class UpdateHSThread implements Runnable { @Override public void run() { // TODO Auto-generated method stub System.out.println("iops线程"); while(true){ Device device; UpdateDeviceStatus update = new UpdateDeviceStatus(); Search search = new Search(); List devicelist = search.getALL("Device"); Iterator deviceitor = devicelist.iterator(); long startTime = System.currentTimeMillis(); try { System.out.println("iops设备数量：" + devicelist.size()); while (deviceitor.hasNext()) { device = (Device) deviceitor.next(); System.out.println("HS连接设备：" + device.getIp()); System.out.println("HSstart"); update.updateHS(device.getFlag(),device.getcinfo()); System.out.println("HSover"); } } catch (Exception e) { e.printStackTrace(); }finally { } long endTime = System.currentTimeMillis(); try { long time = endTime - startTime; Thread.sleep(1000*10); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } } ``` 线程2： ``` import entity.Device; import hibernate.Search; import main.UpdateDeviceStatus; import java.util.Iterator; import java.util.List; public class UpdateDSThread implements Runnable { @Override public void run() { // TODO Auto-generated method stub while (true) { System.out.println("DS进程~~~~~"); Device device = new Device(); UpdateDeviceStatus update = new UpdateDeviceStatus(); Search search = new Search(); List devicelist = search.getALL("Device"); Iterator deviceitor = devicelist.iterator(); while (deviceitor.hasNext()) { device = (Device) deviceitor.next(); try { System.out.println("DS连接设备" + device.getIp()); System.out.println("DSstart"); update.updateDS(device.getFlag(),device.getcinfo()); System.out.println("DSover"); } catch (Exception e) { e.printStackTrace(); } finally { } } try { Thread.sleep(1000 * 60); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } } ``` 一共有两个类似的线程，程序刚刚启动的时候一切正常，但是当过一段时间后会有一个线程不再进行循环，用Thread.getState()查询的线程状态是TIMED_WAITING。 没有异常输出，重启程序后一切正常，两个线程都会每隔规定时间循环一次，但是经过一段时间后又会变成只有一个线程正常循环，另一个停在那。从程序启动到出问题的时间不固定，有的时候一周才出一次，有的时候一小时内就会出。 查不出来是什么问题，求大神解答，挺急的 ``` 线程检查~~~·2017-12-13: 17:19:05 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 iops设备数量：4 HS连接设备：null HSstart HSover HS连接设备：172.10.4.101 HSstart connect 172.10.4.101 success 实时iops 写入iops HSover HS连接设备：172.10.4.200 HSstart connect 172.10.4.200 success 实时iops 写入iops HSover HS连接设备：172.10.4.200 HSstart connect 172.10.4.200 success 实时iops 写入iops HSover 清理历史记录 171213171915 171212171915 startdelete 10 deleteover dh over~~~ 线程检查~~~·2017-12-13: 17:19:18 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 iops设备数量：4 HS连接设备：null HSstart HSover HS连接设备：172.10.4.101 HSstart connect 172.10.4.101 success 实时iops 写入iops HSover HS连接设备：172.10.4.200 HSstart connect 172.10.4.200 success 实时iops 写入iops HSover HS连接设备：172.10.4.200 HSstart connect 172.10.4.200 success 实时iops 写入iops HSover 线程检查~~~·2017-12-13: 17:19:31 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 iops设备数量：4 HS连接设备：null HSstart HSover HS连接设备：172.10.4.101 HSstart connect 172.10.4.101 success 实时iops 写入iops HSover HS连接设备：172.10.4.200 HSstart connect 172.10.4.200 success 实时iops 写入iops HSover HS连接设备：172.10.4.200 HSstart connect 172.10.4.200 success 实时iops 写入iops HSover 检查池容量 iops设备数量：4 HS连接设备：null HSstart HSover HS连接设备：172.10.4.101 HSstart connect 172.10.4.101 success 实时iops 线程检查~~~·2017-12-13: 17:19:44 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 线程检查~~~·2017-12-13: 17:19:57 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 DS进程~~~~~ DS连接设备null DSstart DSover DS连接设备172.10.4.101 DSstart systeminfo connect 172.10.4.101 success 存储池容量 connect 172.10.4.101 success DSover DS连接设备172.10.4.200 DSstart systeminfo connect 172.10.4.200 success 存储池容量 connect 172.10.4.200 success DSover DS连接设备172.10.4.200 DSstart systeminfo connect 172.10.4.200 success 存储池容量 connect 172.10.4.200 success DSover 清理历史记录 171213172002 171212172002 startdelete 8 deleteover dh over~~~ 线程检查~~~·2017-12-13: 17:20:10 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 线程检查~~~·2017-12-13: 17:20:23 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 检查池容量 线程检查~~~·2017-12-13: 17:20:36 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 设备检查 CS连接设备172.10.4.101 connect 172.10.4.101 success nodecanister canistersinfo online online online online drivesinfo psusinfo batteriesinfo CS连接设备172.10.4.200 connect 172.10.4.200 success nodecanister canistersinfo online null drivesinfo CS连接设备172.10.4.200 connect 172.10.4.200 success nodecanister canistersinfo online null drivesinfo 清理历史记录 171213172049 171212172049 startdelete 10 deleteover dh over~~~ 线程检查~~~·2017-12-13: 17:20:49 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 DS进程~~~~~ DS连接设备null DSstart DSover DS连接设备172.10.4.101 DSstart systeminfo connect 172.10.4.101 success 存储池容量 connect 172.10.4.101 success DSover DS连接设备172.10.4.200 DSstart systeminfo connect 172.10.4.200 success 存储池容量 connect 172.10.4.200 success 线程检查~~~·2017-12-13: 17:21:02 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 DSover DS连接设备172.10.4.200 DSstart systeminfo connect 172.10.4.200 success 存储池容量 connect 172.10.4.200 success DSover 线程检查~~~·2017-12-13: 17:21:15 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 线程检查~~~·2017-12-13: 17:21:28 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 检查池容量 清理历史记录 171213172136 171212172136 startdelete 8 deleteover dh over~~~ 线程检查~~~·2017-12-13: 17:21:41 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 线程检查~~~·2017-12-13: 17:21:54 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 DS进程~~~~~ DS连接设备null DSstart DSover DS连接设备172.10.4.101 DSstart systeminfo connect 172.10.4.101 success 存储池容量 connect 172.10.4.101 success DSover DS连接设备172.10.4.200 DSstart systeminfo connect 172.10.4.200 success 存储池容量 connect 172.10.4.200 success DSover DS连接设备172.10.4.200 DSstart systeminfo connect 172.10.4.200 success 存储池容量 connect 172.10.4.200 success DSover 线程检查~~~·2017-12-13: 17:22:07 upds:TIMED_WAITING5 check:TIMED_WAITING5 uphs:TIMED_WAITING7 dh:TIMED_WAITING5 cp:TIMED_WAITING5 ``` 上面是我自己程序中的输出，可以看到刚开始DS和HS两个线程是循环运行的，但是到后面就只有DS了

有关线程收发串口数据的问题_course

最近写一个项目里面用到的是基于串口通信的。 由于我需要一直处于接收数据状态，并且可以随时发送数据（我的串口是RS232，支持全双工），于是想到了用两个线程去做。 一个处于收状态，一个发包用。 现在的问题是：我只有一个SerialPort对象 ，通过跨类的信号和槽得到这个对象，但是一放在线程的run函数读写就会报错。 我曾想过把串口的设置和连接放在线程类里面做，但是我这边两个线程呢，一个链接的话，端口就会被占用，另外一个线程就没法连接 困了一天了 不知道该怎么办 我还想过把收发都放在一个线程里做 不知道这样可不可以 效率怎么样

QT小白提问：QT主线程阻塞、唤醒其他线程_course

想实现主线程控制子线程的功能。 主线程类似于： while { 获取当前子线程 挂起当前子线程 获取下一个运行线程 唤醒下一个运行线程 } 子线程实现如下： void subThreadProcess(void) { while { do something } } 在主线程中只能访问到子线程的接口subThreadProcess，无法知道其内部实现。 现在底层要求用QT实现，能够阻塞或者唤醒选定的线程。 类似于windows中的suspendThread和resumeThread功能。 QT大神帮忙下？谢谢~

线程超时控制问题，怎么实现非阻塞线程超时_course

 使用该线程池方式实现超时管理，必须等待线程运行完毕 时阻塞式的 非阻塞式的怎么实现？

MFC多线程以条件变量或者是消息通知机制来执行子线程问题_course

在MFC做了一个简单的通过网卡发包收包（用的是WinPcap）并加以处理的小程序。一开始实现的方法是发包收包都各自创建了一个线程，每个线程里都有一个while死循环不停轮询看是否有包要发出或者接受处理，这样一运行就把CPU给占用完了，后来分别在两个线程的对应位置加了Sleep（）函数，这样基本不会卡死了，但是感觉效果还是不好。现在想实现的是通过条件变量或者是消息通知这样类似的机制，当发送的包或者接收的包不为空了，再给线程一个通知，告诉它该发送或者接收包了，这时线程才开始执行，否则让它为阻塞状态，不再占用CPU。