qt子线程如何传输数据给主线程

public int _CurrentThread

//form1_load中的，启动线程的代码在这里。

private void Form1_Load(object sender, EventArgs e)

{

//设置最大线程数

int MaxThread = 5

//获取需要完成的任务列表

OleDbConnection AccessConn = AccessModule.Conn("D:\\Flying Co\\flying.mdb")

string sql = "select * from ty_task where bay_flag=" + false + " order by bay_id asc"

OleDbCommand comm = new OleDbCommand(sql, AccessConn)

OleDbDataReader list = comm.ExecuteReader()

while (list.Read())

{

ContentParse Spider = new ContentParse()

//如果当前活动线程超过最大线程数，线程休眠

if (Spider.CurrentThread>MaxThread)

{

Thread.Sleep(2000)

}

else

{

//init

Spider.Url = list["bay_task"].ToString()

//启动一个线程

Thread SpiderThread = new Thread(new ThreadStart(Spider.execute))

SpiderThread.Start()

MessageBox.Show(Spider.CurrentThread.ToString())

//任务设置为已处理

sql = "update ty_task set bay_flag=" + true + " where bay_id=" + list["bay_id"].ToString()

AccessModule.Execute(AccessConn, sql)

}

}

list.Close()

AccessModule.DisConn(AccessConn)

}

//线程启动的是这个类的方法

class ContentParse

{

private string _Url

//设置任务参数

public string Url

{

set

{

_task = value

}

}

public void execute()

{

//活动线程数加1

Interlocked.Increment(ref _CurrentThread)

//中间处理任务的代码省略

//该线程完成，活动线程减1

Interlocked.Decrement(ref _CurrentThread)

}

我现在纠结的就是这个Interlocked.Increment(ref _CurrentThread)应该是开一个线程就要加1的对吧？

但是我在form1中间用 MessageBox.Show(Spider.CurrentThread.ToString())，总是0噢

在Qt里面是QThread吧，如果是多线程要在一个类里面也没啥问题，效率那主要就是考虑你线程干什么工作了，在Qt里面，你可以直接继承QThread类并实现它的run方法就可以了

class Worker_1 : public QThread

{

public:

Worker_1()

~Worker_1()

protected:

virtual void run() { // do somthing }

}

class Work_2 //你同样可以写出Work_2这个类

class WorkManager : QObject

{

Q_OBJECT

//......

public:

void start()

{

w1.start()

w2.start()

}

private:

Worker_1 w1

Worker_2 w2

}

// test main function

int main（void)

{

WorkManager wm

wm.start()

while(1) QThread::sleep(300000)

}

在Qt里面QMutex、QSemphore只可以用来做线程间同步，如果你涉及到多线程共享资源的访问的话

两个线程间传递QByteArray，如果这个QbyteArray非常大的话，你建议你使用共享内存的方式，当然如果情况还好，可以使用Qt的信号与槽机制

1、线程内注册与连接数据库的竞争问题

文档上对多线程下数据库应用的注意事项写的很简明，一个线程创建的 QSqlDatabase 对象和 查出来的 QSqlQuery 对象只能给本线程用（注意，是对象，不是数据库连接本身，连接本身用名字可以多线程使用），其他情况是“不支持的”。在一个需要有几个线程并发访问不同数据库的应用中，我首先试图在各个线程的起始分别以不同的名称调用 addDatabase / database 、open，但是程序偶然会崩溃，跟踪后发现，虽然Qt 声称很多方法是“线程安全”的，但是几个方法串起来，就出问题了。Qt 会动态的加载数据库的plugin, 加载 plug in 的部分，涉及到对本地库文件的管理，这一部分，出现了竞争。于是，很自然的想到在初始连接部分设置 Mutex 保护，从 addDatabase / database到 open 的部分，要保证其原子性，问题再也没有出现。

2、数据库连接意外断裂后，恢复连接的问题

在MFC 中，一旦中途TCP连接断裂，直接重新 Open 就可以了。在Qt 里，这一招不好使了。即便 调用了 close ，再次open 也是不行的。处理方法：

在检测到问题出现后，关闭连接，并 removeDatabase； 而后，不要立刻 addDatabase, 反而是要回到该连接所在的事件循环。没有详细跟源码，很可能在 removeDatabase 后的事件循环中，Qt 内部做了一些释放 *** 作。 怎么办呢， 可以设置一个恢复定时器，比如 1分钟，重新 addDatabase，就可以啦。如果心急的话，直接显式调用processEvent() 方法强制循环。

在多线程下，注意1中的问题，需要 Mutex保护。

3、数据库插件的依赖性问题

在 Windows 下，有时我们的机器上按了好几个 Qt 版本，PATH里索性神马也不设置，依赖开发环境的继承环境适应不同的版本。这有两个问题。一是发布程序的时候，数据库驱动依赖的dll 也要与可执行文件在同一路径下发布。比如 mysql 的 dll, PostgreSQL 的依赖等。二是在集成开发环境中，这些依赖也要位于执行档文件夹下。否则，会造成虽然可以枚举到可用驱动，但是死活连接不上。调试一下就知道，原来是在路径中找不到依赖项，导致dll加载失败哦！

---