`
cakin24
  • 浏览: 1409702 次
  • 性别: Icon_minigender_1
  • 来自: 西安
社区版块
存档分类
最新评论

Worker子线程之间的数据交换应用

阅读更多
一 应用
1、第一条Worker线程负责收集指定范围内的质数。
2、第二条Worker线程负责从指定范围的质数中随机抽取指定数量的质量。
 
二 代码
1、calPrime.html
<!DOCTYPE html>
<html>
<head>
	<meta name="author" content="Yeeku.H.Lee(CrazyIt.org)" />
	<meta http-equiv="Content-Type" content="text/html; charset=GBK" />
	<title> 计算质数 </title>
	<style type="text/css">
		#show {
			width: 400px;
			background-color: #ddd;
			border-collapse: collapse;
		}
		td {
			border: 1px solid #555;
		}
	</style>
</head>
<body>
	起始值:<input type="text" id="start" name="start"/><br/>
	结束值:<input type="text" id="end" name="end"/><br/>
	个数:<input type="text" id="count" name="count"/><br/>
	<input type="button" value="计算" onclick="cal();"/>
	<table id="show"></table>
	<script type="text/javascript">
		var cal = function()
		{
			// 得到用户输入的start、end两个值
			var start = parseInt(document.getElementById("start").value);
			var end = parseInt(document.getElementById("end").value);
			var count = parseInt(document.getElementById("count").value);
			// 如果start大于、等于end,直接结束该函数
			if (start >= end)
			{
				return;
			}
			// 启动第一个Worker线程,该线程用于计算、收集指定范围内的所有质数
			var cal = new Worker("worker1.js");
			// 定义需要提交给Worker线程的数据
			var data = {
				start : start,
				end : end
			};
			// 向Worker线程提交数据。
			cal.postMessage(JSON.stringify(data));
			// 监听onmessage方法,获取worker1.js对应的的Worker线程返回的数据
			cal.onmessage = function(event)
			{
				// 启动第二个Worker线程,该线程用于随机抽取count个质数
				var rand = new Worker("worker2.js");
				rand.postMessage({result: event.data , count : count});
				// 监听onmessage方法,获取worker2.js对应的的Worker线程返回的数据
				rand.onmessage = function(event)
				{
					var table = document.getElementById("show");
					// 清空该表格原有的内容
					table.innerHTML = "";
					// 获取Worker线程返回的数据
					var result = event.data;
					var nums = result.split(",");
					// 定义表格总共包含多少列
					var COLS_NUM = 7;
					for (var i = 0 ; i <= (nums.length - 1) / COLS_NUM ; i++)
					{
						// 添加表格行
						var row = table.insertRow(i);
						// 循环插入7个单元格
						for(var j = 0 ; j < COLS_NUM &&
							i * COLS_NUM + j < nums.length - 1 ; j++)
						{
							// 插入单元格、并为单元格设置innerHTML属性
							row.insertCell(j).innerHTML = nums[i * COLS_NUM + j]
						}
					}
				};
			};
		};
	</script>
</body>
</html>
 
2、worker1.js
onmessage = function(event)
{
	// 将数据提取出来。
	var data = JSON.parse(event.data);
	// 取出start参数
	var start = data.start;
	// 取出end参数
	var end = data.end;
	var result = "";
	search:
	for (var n = start ; n <= end ; n++)
	{
		for (var i = 2; i <= Math.sqrt(n); i ++)
		{
			// 如果除以n的余数为0,开始判断下一个数字。
			if (n % i == 0)
			{
				continue search;
			}
		}
		// 搜集找到的质数
		result += (n + ",");
	}
	// 把需要处理的数据传入启动该Worker线程的宿主脚本中
	postMessage(result);
}
 
3、worker2.js
onmessage = function(event)
{
	// 将数据提取出来。
	var data = event.data;
	// 提取所有质数
	var primeNums = data.result.split(",")
	var randResult = "";
	for (var i = 0 ; i < data.count ; i++ )
	{
		// 计算一个随机索引值
		var randIndex = Math.floor(Math.random()
			* (primeNums.length - 1));
		// 随机地"收集"一个质数
		randResult += (primeNums[randIndex] + ",");
	}
	// 发送消息,将会触发启动它的JavaScript脚本中
	// 对应Worker对象的onmessage方法
	postMessage(randResult);
}
 
 
三 运行结果


 
  • 大小: 21.8 KB
1
1
分享到:
评论

相关推荐

    QT多线程—主界面卡死解决方案

    3. 使用信号与槽机制进行通信:主线程和工作线程之间的数据交换或通知通常通过信号和槽来实现。当工作完成时,工作线程可以发射一个信号,主线程接收到这个信号后执行相应的UI更新。 ```cpp // 在WorkerObject中...

    html5 worker 实例(一) 为什么测试不到效果

    在实际应用中,通常会使用JSON格式的数据进行传输,以便于在主线程和Worker之间交换复杂的信息。 总之,HTML5 Worker 提供了一种在浏览器环境中进行后台计算的方式,通过正确部署到服务器并遵循浏览器的安全策略,...

    Handler_Message_Looper小结

    - 主线程中的 `mHandler` 收到消息后,会调用 `handleMessage()` 方法处理消息,从而实现了跨线程通信和数据交换。 #### 四、总结 `Handler`, `Message`, `Looper` 和 `MessageQueue` 是 Android 应用开发中非常...

    python中的多线程与多进程及其区别(csdn)————程序.pdf

    进程间无法直接共享内存,但可以通过以下方式交换数据: - **管道(Pipe)**:简单、直接的通信方式,适合小量数据传递。 - **共享内存(Shared Memory)**:通过`multiprocessing`模块中的`Value`和`Array`实现,...

Global site tag (gtag.js) - Google Analytics