基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：78630559

本次赞助数额为： 1 元　

支付宝支付

微信支付

   源码介绍

---

example(多线程模板).rar

#include "stdafx.h"
#include "script.h"
#include "thread_control.h"
#include "log.h"

void DoWork(long index);
unsigned WINAPI SubThread(PVOID pParam);
void CheckException(long index);

// 我们做暂停和恢复操作,就主要靠这个延时函数,要求脚本所有用到延时的地方，全部用这个，这样我们可以有很多机会去暂停线程
void ScriptDelay(long index,long time)
{
	// 判断是否有暂停和结束标记
	if (g_info[index].is_stop)
	{
		// 直接退出当前线程,退出前一定要在本线程内解绑,因为绑定模式0和2在线程外解绑的话会失败,导致解绑失败.
		if (g_info[index].dm)
		{
			g_info[index].dm->UnBindWindow();
		}
		_endthreadex(0);
	}

	if (g_info[index].is_pause)
	{
		g_info[index].thread_state = State_Pause;
		ThreadNotifyUI_Post(NOTIFY_UPDATE,index);

		// 如果你想要在暂停时让用户可以操作,那么可以调用EnableBind,但是不要去调用LockInput,LockInput不是用来解除后台的,具体参考LockInput的说明
		if (g_info[index].dm)
		{
			g_info[index].dm->EnableBind(5);
		}

		// 我们暂停的方法是死循环,然后延时,而不是调用系统的接口
		// 这样开销最小,并且效率也还不错
		while (1)
		{
			if (!g_info[index].is_pause)
			{
				g_info[index].thread_state = State_Runing;
				ThreadNotifyUI_Post(NOTIFY_UPDATE,index);
				
				// 开启后台
				if (g_info[index].dm)
				{
					g_info[index].dm->EnableBind(1);
				}
				break;
			}

			if (g_info[index].is_stop)
			{
				// 直接退出当前线程,退出前一定要在本线程内解绑,因为绑定模式0和2在线程外解绑的话会失败,导致解绑失败.
				if (g_info[index].dm)
				{
					g_info[index].dm->UnBindWindow();
				}
				_endthreadex(0);
			}

			Sleep(1);
		}
	}

	// 可能暂停,恢复时会让状态错乱,这里再判断一次
	if (g_info[index].thread_state != State_Runing)
	{
		g_info[index].thread_state = State_Runing;
		ThreadNotifyUI_Post(NOTIFY_UPDATE,index);

		// 开启后台
		if (g_info[index].dm)
		{
			g_info[index].dm->EnableBind(1);
		}
	}

	Sleep(time);
}

void SetTaskState(long index,const TCHAR * state)
{
	_tcscpy(g_info[index].task_state,state);
	ThreadNotifyUI_Post(NOTIFY_UPDATE,index);
}

// 脚本主线程,脚本的主要逻辑在这里处理
unsigned WINAPI MainThread(PVOID pParam)
{
	long index = (long)(DWORD_PTR)pParam;
	dmsoft * dm;

	// 初始化当前线程com组件为MTA模式
	CoInitializeEx (NULL,0);

	g_info[index].thread_state = State_Runing;
	ThreadNotifyUI_Post(NOTIFY_UPDATE,index);

	// 创建对象
	g_info[index].dm = new dmsoft;
	dm = g_info[index].dm;

	// 检测对象是否创建成功,虽然这个一般不会失败,但为了程序健壮性考虑还是加上,如果内存吃紧，还是可能会失败
	if (dm == NULL || dm->Ver().GetLength() == 0)
	{
		Log(_T("对象创建失败"));
		ThreadNotifyUI_Post(NOTIFY_STOP,index);
		return 0;
	}

	// 开启全局共享字库
	dm->EnableShareDict(1);

	// 其他设置,比如路径等等
	dm->SetPath(_T("c:\test_game"));

	// 开始绑定,主绑定一定要第一个绑定,并且主绑定所在的线程绝对不能结束,否则会造成绑定失效
	long dm_ret = dm->BindWindowEx(g_info[index].hwnd,_T("normal"),_T("normal"),_T("dx"),_T("dx.public.anti.api"),0);
	if (dm_ret != 1)
	{
		Log(_T("主:绑定失败，错误码:%d"),dm->GetLastError());
		// 通知主线程进行结束操作(释放资源)
		ThreadNotifyUI_Post(NOTIFY_STOP,index);
		return 0;
	}

	// 禁止输入
	dm->LockInput(4);

	// 我们可以创建副线程了
	// 更新副线程信息
	g_info[index MAX_HWND].thread_state = State_Starting;

	// 通知UI,副线程开始创建了
	ThreadNotifyUI_Post(NOTIFY_UPDATE,index MAX_HWND);

	// 创建副线程
	g_info[index MAX_HWND].handle = (HANDLE)_beginthreadex(0, 0, SubThread, (PVOID)(DWORD_PTR)(index MAX_HWND), 0, 0);
	if (g_info[index MAX_HWND].handle == NULL)
	{
		// 这里必须要解绑,因为模式0和2不在当前线程解绑的话,会导致无法解绑
		dm->UnBindWindow();

		Log(_T("创建副线程失败"));
		// 通知主线程进行结束操作(释放资源)
		ThreadNotifyUI_Post(NOTIFY_STOP,index);
		return 0;
	}


	while (1)
	{
		SetTaskState(index,_T("开始做任务"));
		DoWork(index);
		SetTaskState(index,_T("任务完成"));
		ScriptDelay(index,1000);
	}
}

void DoWork(long index)
{
	dmsoft * dm = g_info[index].dm;

	dm->KeyPressChar(_T("m"));
	ScriptDelay(index,500);
}

void SetExcepState(long index,const TCHAR * state)
{
	_tcscpy(g_info[index].excep_state,state);
	ThreadNotifyUI_Post(NOTIFY_STOP,index);
}

// 脚本副线程,用于检测异常等
unsigned WINAPI SubThread(PVOID pParam)
{
	long index = (long)(DWORD_PTR)pParam;

	dmsoft * dm;

	// 初始化当前线程com组件为MTA模式
	CoInitializeEx (NULL,0);

	g_info[index].thread_state = State_Runing;
	ThreadNotifyUI_Post(NOTIFY_UPDATE,index);

	// 创建对象
	g_info[index].dm = new dmsoft;
	dm = g_info[index].dm;

	// 检测对象是否创建成功,虽然这个一般不会失败,但为了程序健壮性考虑还是加上,如果内存吃紧，还是可能会失败
	if (dm == NULL || dm->Ver().GetLength() == 0)
	{
		Log(_T("对象创建失败"));
		SetExcepState(index,_T("对象创建失败"));
		return 0;
	}

	// 开启全局共享字库
	dm->EnableShareDict(1);

	// 其他设置,比如路径等等
	dm->SetPath(_T("c:\test_game"));

	long dm_ret = dm->BindWindowEx(g_info[index].hwnd,_T("normal"),_T("normal"),_T("dx"),_T("dx.public.anti.api"),0);
	if (dm_ret != 1)
	{
		Log(_T("副:绑定失败，错误码:%d"),dm->GetLastError());
		// 通知主线程进行结束操作(释放资源)
		SetExcepState(index,_T("副:绑定失败"));
		return 0;
	}


	while (1)
	{
		// 检测一些异常,比如突然弹出的对话框，目标窗口被关闭或者掉线等突发情况
		// 比如检测到掉线，可考虑通知UI,然后重新运行
		CheckException(index);
		ScriptDelay(index,3000);
	}
}

void CheckException(long index)
{
	dmsoft * dm = g_info[index].dm;

	// 检测窗口是否存在
	if (dm->GetWindowState(g_info[index].hwnd,0) == 0)
	{
		SetExcepState(index,_T("窗口不见了"));
	}

	// 检测窗口是否卡死



	// 检测是否掉线


	// 检测是否有弹出窗口



	// 其他检测
	dm->KeyPressChar(_T("s"));
}