提交
相关推荐
- 回答 2 已采纳 主线程栈里不是只能同步执行一个任务么？是不是promise.all告诉浏览器，让浏览器的多线程帮忙执行多个promise任务？我想知道答案，谢谢大佬指点！
- 回答 2 已采纳 I have a Go file with unit tests and some of them use a common variable. Another global variable is used in the code that I'm testing. All of this can cause a problem. In Go when we execute tests that are located in the same file how does they run? In parallel or next one will not start before previous one is finished ?
- 回答 2 已采纳 I have multiple Goroutines sharing a net.Conn object. Can they issue a Write calls simultaneously? My main concern is that of Write calls which are partially done. Say I intend to wrote 100 bytes, but only 30 were sent, so I need to send 70 more. For this I will typically write a loop: count := 0 for count < len(buf) { byteSent, err := conn.Write(buf[count:]) //check error count += byteSent } But I see that Go implements this loop in net.Conn.Write line number 318 and it does so by taking a lock. However, on Windows implementation there is no such loop except that there is a call to WSASend. I do not know how WSASend behaves and could not get much from the MSDN docs Hence the questions are: [edit] Added 4th question Do I need to acquire a lock everytime I write to socket? If yes, then the purpose of acquiring the lock in Write implementation is defeated. In unix implementation, does it mean that I cannot get byteSent < len(buf) unless err != nil? (I mean am I reading the code correct?) Does the WSASend on Windows implements the equivalent loop in Unix implementation
- 回答 3 已采纳 我是在win8 64bit上面操作，本来安装的nodejs是64位的， npm install时一直出现错误，上网查后有说要安装32位的，而且需要安装vs， 于是我卸载64的node又安装32的node，又安装vs2012， 然后又npm install 出现如下异常： ``` npm WARN optional dep failed, continuing fsevents@0.3.8 \ > spawn-sync@1.0.13 postinstall E:\project2\shijuan\node_modules\node-sass\node_modules\sas modules\spawn-sync > node postinstall \ > node-sass@3.2.0 install E:\project2\shijuan\node_modules\node-sass > node scripts/install.js Binary downloaded and installed at E:\project2\shijuan\node_modules\node-sass\vendor\win32- > node-sass@3.2.0 postinstall E:\project2\shijuan\node_modules\node-sass > node scripts/build.js ` E:\project2\shijuan\node_modules\node-sass\vendor\win32-ia32-14\binding.node ` exists. testing binary. Binary is fine; exiting. \ > bufferutil@1.1.0 install E:\project2\shijuan\node_modules\webpack-dev-server\node_modules > node-gyp rebuild | (venv) Think@RESEARCH E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\sock > if not defined npm_config_node_gyp (node "C:\Program Files (x86)\nodejs\node_modules\npm\ e rebuild ) 在此解决方案中一次生成一个项目。若要启用并行生成，请添加“/m”开关。 bufferutil.cc 正在创建库 E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\socket.io\ util .expb 和对象 E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\socket.io\n 正在生成代码 已完成代码的生成 bufferutil.vcxproj -> E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\so se\\bufferutil.node | > utf-8-validate@1.1.0 install E:\project2\shijuan\node_modules\webpack-dev-server\node_mod f-8-validate > node-gyp rebuild / (venv) Think@RESEARCH E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\sock ate > if not defined npm_config_node_gyp (node "C:\Program Files (x86)\nodejs\node_modules\npm\ e rebuild ) 在此解决方案中一次生成一个项目。若要启用并行生成，请添加“/m”开关。 validation.cc 正在创建库 E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\socket.io- ild\ Release\validation.lib 和对象 E:\project2\shijuan\node_modules\webpack-dev-server\node_mo tf -8-validate\build\Release\validation.exp 正在生成代码 已完成代码的生成 validation.vcxproj -> E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\so lidate\build\Release\\validation.node > utf-8-validate@1.1.0 install E:\project2\shijuan\node_modules\webpack-dev-server\node_mod > node-gyp rebuild (venv) Think@RESEARCH E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\sock > if not defined npm_config_node_gyp (node "C:\Program Files (x86)\nodejs\node_modules\npm\ e rebuild ) 在此解决方案中一次生成一个项目。若要启用并行生成，请添加“/m”开关。 validation.cc 正在创建库 E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\socket.io\ lida tion.lib 和对象 E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\socket.i va lidation.exp 正在生成代码 已完成代码的生成 validation.vcxproj -> E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\so elease\\validation.node > bufferutil@1.1.0 install E:\project2\shijuan\node_modules\webpack-dev-server\node_modules util > node-gyp rebuild (venv) Think@RESEARCH E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\sock > if not defined npm_config_node_gyp (node "C:\Program Files (x86)\nodejs\node_modules\npm\ e rebuild ) 在此解决方案中一次生成一个项目。若要启用并行生成，请添加“/m”开关。 bufferutil.cc 正在创建库 E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\socket.io- Rele ase\bufferutil.lib 和对象 E:\project2\shijuan\node_modules\webpack-dev-server\node_module ru til\build\Release\bufferutil.exp 正在生成代码 已完成代码的生成 bufferutil.vcxproj -> E:\project2\shijuan\node_modules\webpack-dev-server\node_modules\so il\build\Release\\bufferutil.node vinyl-named@1.1.0 node_modules\vinyl-named └── through@2.3.8 manifest-revision-webpack-plugin@0.0.5 node_modules\manifest-revision-webpack-plugin └── walk@2.3.9 (foreachasync@3.0.0) coffee-script@1.9.3 node_modules\coffee-script superagent@1.3.0 node_modules\superagent ├── extend@1.2.1 ├── methods@1.0.1 ├── cookiejar@2.0.1 ├── component-emitter@1.1.2 ├── reduce-component@1.0.1 ├── mime@1.3.4 ├── qs@2.3.3 ├── debug@2.2.0 (ms@0.7.1) ├── readable-stream@1.0.27-1 (inherits@2.0.1, isarray@0.0.1, string_decoder@0.10.31, core-u ├── formidable@1.0.14 └── form-data@0.2.0 (async@0.9.2, combined-stream@0.0.7, mime-types@2.0.14) ``` 其实看上去也成功了很多，但是前面那几个异常怎么解决呢？谢谢各位 package.json如下 ``` { "repository": { "type": "git", "url": "" }, "license": "MIT", "description": "Project Shijuan", "scripts": { "start": "node_modules/.bin/webpack-dev-server --config conf/webpack.config.js --progress --colors --port 5001 --content-base build/public", "build": "node_modules/.bin/webpack --config conf/webpack.config.js --progress --profile --colors" }, "dependencies": { "amazeui": "^2.4.2", "babel-core": "^5.4.7", "babel-loader": "^5.1.3", "coffee-loader": "^0.7.2", "coffee-script": "^1.9.3", "css-loader": "^0.15.6", "echarts": "^2.2.7-beta7", "extract-text-webpack-plugin": "^0.8.1", "file-loader": "^0.8.4", "html-loader": "^0.3.0", "jquery": "^2.1.4", "manifest-revision-webpack-plugin": "^0.0.5", "node-sass": "^3.2.0", "postcss-loader": "^0.5.1", "sass-loader": "^2.0.0", "style-loader": "^0.12.3", "superagent": "^1.3.0", "url-loader": "^0.5.6", "vinyl-named": "^1.1.0", "vue": "^0.12.10", "vue-loader": "^2.1.1", "vue-validator": "^1.4.0", "webpack": "^1.10.0", "webpack-dev-server": "^1.9.0", "zrender": "ecomfe/zrender" } } ```
- 回答 2 已采纳 ``` res: (respnse) => { console.info(respnse.result.active) let url = respnse.result.active == 'dev' ?'http://10.68.105.145:8081/sxhblh-boot/trainmanage/trainInfo/visitImg?imgName=' + respnse.result.url :'http://ctg.com.cn:8081/sxhblh-boot/trainmanage/trainInfo/visitImg?imgName=' + respnse.result.url return url }, ``` @GetMapping("visitImg") @ResponseBody public synchronized void visitImg(String imgName,HttpServletResponse response){ String path; InputStream inputStream = null; BufferedInputStream bufferedInputStream = null; BufferedOutputStream bufferedOutputStream = null; try { path = "img"; inputStream = FtpClientUtil.readFile(imgName,path); bufferedInputStream = new BufferedInputStream(inputStream); bufferedOutputStream = new BufferedOutputStream(response.getOutputStream()); byte[] buf = new byte[1024 * 1024]; int length = 0; while ((length = bufferedInputStream.read(buf)) != -1) { bufferedOutputStream.write(buf, 0, length); bufferedOutputStream.flush(); } } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { try { inputStream.close(); bufferedInputStream.close(); bufferedOutputStream.close(); } catch (IOException e) { e.printStackTrace(); } } } ``` ``` 如第一段代码所示，这是上传图片后的回调，给图片设置src，可以看到，所有的图片访问调用的都是同一个接口visitImg，参数为imgName，现在的问题是，上传多个图片后，始终只能显示第一个图片，后面的图片都无法显示，后台报错stream closed流关闭，但是我打了断点之后，会进多次断点，并且图片都能显示，然后我在想是不是打了断点之后，上一次请求阻塞下一次请求，使得本来所有图片的访问从并行变为了串行，由此思考我想到了一个解决办法，给方法加上锁synchronized，问题解决了。问题是解决了，但是问题的本质我还是没有弄懂，1、为什么并行访问接口会导致stream closed流被关闭，2、还有没有更好的解决办法（一开始还想在前端设置请求队列，但是请求是以src的形式，所以放弃了），还请各位大神们赐教
- 4年前回答 2 已采纳 I made this script for getting the follower count of "influencers" from instagram the "runtime" number I am getting from it is between 550-750ms. It is not that bad, but I am wondering whether it could be better or not (as I am a golang noob - learning it 3 weeks only) package main import ( "encoding/json" "fmt" "io/ioutil" "log" "net/http" "sync" "time" ) type user struct { User userData `json:"user"` } type userData struct { Followers count `json:"followed_by"` } type count struct { Count int `json:"count"` } func getFollowerCount(in <-chan string) <-chan int { out := make(chan int) go func() { for un := range in { URL := "https://www.instagram.com/" + un + "/?__a=1" resp, err := http.Get(URL) if err != nil { // handle error fmt.Println(err) } defer resp.Body.Close() body, err := ioutil.ReadAll(resp.Body) var u user err = json.Unmarshal(body, &u) if err != nil { fmt.Println(err) } // return u.User.Followers.Count out <- u.User.Followers.Count } close(out) }() return out } func merge(cs ...<-chan int) <-chan int { var wg sync.WaitGroup out := make(chan int) output := func(c <-chan int) { for n := range c { out <- n } wg.Done() } wg.Add(len(cs)) for _, c := range cs { go output(c) } go func() { wg.Wait() close(out) }() return out } func gen(users ...string) <-chan string { out := make(chan string) go func() { for _, u := range users { out <- u } close(out) }() return out } func main() { start := time.Now() fmt.Println("STARTING UP") usrs := []string{"kanywest", "kimkardashian", "groovyq", "kendricklamar", "barackobama", "asaprocky", "champagnepapi", "eminem", "drdre", "g_eazy", "skrillex"} in := gen(usrs...) d1 := getFollowerCount(in) d2 := getFollowerCount(in) d3 := getFollowerCount(in) d4 := getFollowerCount(in) d5 := getFollowerCount(in) d6 := getFollowerCount(in) d7 := getFollowerCount(in) d8 := getFollowerCount(in) d9 := getFollowerCount(in) d10 := getFollowerCount(in) for d := range merge(d1, d2, d3, d4, d5, d6, d7, d8, d9, d10) { fmt.Println(d) } elapsed := time.Since(start) log.Println("runtime", elapsed) }
- 回答 3 已采纳 分布式计算.网格计算.云计算.透明计算.并行计算.这个计算怎么理解，计算是数据处理吗，那这个数据处理和编程等程序设计是什么关系 具体说一下编程和这些计算是什么关系，望高手详解，复制粘贴就算了。
- 回答 2 已采纳 I have seen people setting runtime.GOMAXPROCS to runtime.NumCPU() to enable parallel processing in go. Official documentation doesn't say anything about the upper bound of GOMAXPROCS; can I set this to any arbitrary positive integer or should it always be less than eq. to NumCPU value? I tried setting it to a number that's greater than the # of logical cores, my code works just fine
- 回答 1 已采纳 1、读取“d:/users/v-lingao/from_lei/wordsegmentation/testdata”目录下的所有txt文档，利用Parallel.For并行处理各个txt文档中的内容，每次读取一行存储到string line中，利用line = sr.ReadLine() （StreamReader sr); 没处理一行也入“d:/users/v-lingao/from_lei/wordsegmentation/testdata1”目录下新创建的对应的txt文件中。方法ComputeIDF()实现次功能。 2、读取在“d:/users/v-lingao/from_lei/wordsegmentation/testdata1”目录下创建的txt文件，利用Parallel.For并行处理每个txt文档中的内容，类似于ComputeIDF（）方法，利用line = sr.ReadLine().。法ComputingTfIdf()实现此功能。错误也就出现在此方法中，错误提示根据写入文件时编码方式的不同有所改变。 部分代码如下所示： public static Dictionary ComputeIDF(List stopWordsList) { DirectoryInfo di = new DirectoryInfo(@"d:/users/v-lingao/from_lei/wordsegmentation/testdata"); FileInfo[] ff = di.GetFiles("*.txt"); Dictionary featureDoc = new Dictionary(); Parallel.For(0, ff.Length, (part) => { FileInfo file = ff[part]; Dictionary featureFile = new Dictionary(); string name = file.Name.Substring(file.Name.LastIndexOf("\\") + 1); string path = Path.Combine(@"d:/users/v-lingao/from_lei/wordsegmentation/testdata1", name); FileStream aFile = new FileStream(path, FileMode.Create); StreamWriter sw = new StreamWriter(aFile, Encoding.UTF8); int lineCount = 0; char[] charArray = new char[] { ' ' }; StreamReader sr = new StreamReader(file.OpenRead(),Encoding.UTF8); string line = sr.ReadLine(); while (line != null) { //部分代码省略 lineCount++; sw.Write(lineCount); foreach (KeyValuePair keyvalue in featureLine) { sw.Write(' ' + keyvalue.Key + ':' + (0.5 + 0.5 * ((float)keyvalue.Value / maxCount))); } sw.WriteLine(); line = sr.ReadLine(); } //combine the featureFiles into featureDoc without repeating featureDoc.Add(featurename, featureFile[featurename]); sr.Close(); sw.Close(); }); Dictionary idf = new Dictionary(); foreach (KeyValuePair keyvalue in featureDoc) { idf.Add(keyvalue.Key, (float)Math.Log10((float)sumLine / (float)keyvalue.Value)); } return idf; } 这个方法没有问题。接下来是ComputingTfIdf（idf），问题出在这个方法中。 public static void ComputingTfIdf(Dictionary idf) { DirectoryInfo dir = new DirectoryInfo(@"d:/users/v-lingao/from_lei/wordsegmentation/testdata1"); FileInfo[] ff = dir.GetFiles("*.txt"); StreamReader sr; Parallel.For(0, ff.Length, (part) => { FileInfo file = ff[part]; List idfList = new List(); idfList.AddRange(idf.Keys); int linenum = 0; sr = new StreamReader(file.OpenRead(),Encoding.UTF8); char[] charArray = new char[] { ' ' }; char[] charArray1 = new char[] { ':' }; string name = file.Name.Substring(file.Name.LastIndexOf("\\") + 1); string path = Path.Combine(@"d:/users/v-lingao/from_lei/wordsegmentation/idfdata", name); FileStream aFile = new FileStream(path, FileMode.Create); StreamWriter sw = new StreamWriter(aFile, Encoding.UTF8); ** *string line = sr.ReadLine();* ** //这行有时也会出错 while (line != null) { linenum++; string[] words = line.Split(charArray); int i = 1; foreach (string word in words) { if (i == 1) { sw.Write(word + ' '); i++; } else { string[] wds = word.Split(charArray1); if (wds.Length == 2) { string key = wds[0]; if (idf.Keys.Contains(key)) { double tfidf = (double)idf[key] * (Convert.ToDouble(wds[1])); sw.Write(idfList.IndexOf(key)+ ':'+tfidf +' '); } } } } sw.WriteLine(); ** *line = sr.ReadLine();* ** //问题常常出现在这行 } } sw.Close(); }); } 错误提示根据写入文件时编码方式的不同有所改变。当读取、写入文件用UTF8或者Unicode时，写入和读取的都是乱码，并且line = sr.ReadLine()出错，错误提示为： ** *The output char buffer is too small to contain the decoded characters, encoding 'Unicode (UTF-8)' fallback 'System.Text.DecoderReplacementFallback'* ** 很是无语，功能相同的代码，为什么ComputeIDF（）方法中line = sr.ReadLine()就不出错。我将编码换成Encoding.GetEncoding("GBK")读写文件不会出现乱码，但line = sr.ReadLine()还是出错，相当无语！ 还有就是当不用并行处理Parallel.For，而是用for循环时也不出错。 求大侠帮忙，不胜感激！
- 回答 1 已采纳 In this article on wikipedia: https://en.wikipedia.org/wiki/Go_(programming_language)#Suitability_for_parallel_programming It is claimed that the go expert used a distribute-work-synchronize pattern to organize his parallel programs, while the non-expert used a fork-join: https://upload.wikimedia.org/wikipedia/commons/thumb/f/f1/Fork_join.svg/2000px-Fork_join.svg.png I am familiar with the fork-join from school, but I was wondering what the distribute-work-synchronize pattern is, and what the differences are between it and the classical fork-join model that i'm familiar with? When I do fork join I typically run as many threads as I do cores, but in the paper they say the go expert did this as well, and they briefly mention the overhead of creating new threads being one of the ways the go expert optimized the code, but don't seem to go into detail.
- weixin_39859055的博客 比较前卫的学校，比如 CMU，早在很多年前就已经在算法入门课(本科二年级)直接教授本科生并行算法而不再局限于串行算法了——因为串行算法就是并行算法在一个核上跑嘛！相信这也会成为未来世界上所有学校的大趋势。这...
- 是权的博客 不知道当大家为什么对ug...它在诞生之初主要是基于工作站，但随着PC硬件的发展和个人用户的快速增长，PC上的应用实现了快速增长，并且已经成了目前模具制造加工业三维产品加工编程和产品设计中的主流应用。UG的发...
- AI科技大本营的博客 比较前卫的学校，比如 CMU，早在很多年前就已经在算法入门课（本科二年级）直接教授本科生并行算法而不再局限于串行算法了——因为串行算法就是并行算法在一个核上跑嘛！ 相信这也会成为未来世界上所有学校的大趋势...
- 2年前chuping3256的博客 一直以来并发编程对于刚入行的小白来说总是觉得高深莫测，于是乎，就诞生了想写点东西记录下，以提升理解和堆并发编程的认知。...以及在进行并发编程时应该了解和掌握的概念是什么？这篇文章主要以这三个问题来谈...
- weixin_39618956的博客 公众号官方提示：点↑"UG编程"关注，免费学UG不知道当大家为什么对ug编程产生兴趣的呢？是因为兴趣爱好，还是想自我的提升呢？UG是Unigraphics的简称，Unigraphics是一个交互式的CAD/CAM系统。它功能强大，可以方便...
- weixin_39856265的博客 公众号官方提示：点↑"UG编程"关注，免费学UG不知道当大家为什么对ug编程产生兴趣的呢？是因为兴趣爱好，还是想自我的提升呢？UG是Unigraphics的简称，Unigraphics是一个交互式的CAD/CAM系统。它功能强大，可以方便...
- 3年前慕辰666的博客 俗话说隔行如隔山，一点都没错，现在我就冒着被小伙伴追杀的危险，给大家说道说道问前端、后端、前台、后台的概念，聊一下程序员每天在忙啥，你会明白，不同岗位的到底有什么区别。1.前端开发先说说前端开发。前端...
- 3年前bruce135lee的博客 随着多核时代的到来，并行开发越来越展示出它的强大威力！使用并行程序，充分的利用系统资源，提高程序的性能。在.net 4.0中，微软给我们提供了一个新的命名空间：System.Threading.Tasks。这里面有很多关于并行开发...
- 商业纪事的博客 UG编程是干嘛的？UG是Unigraphics的简称，Unigraphics是一个交互式的CAD/CAM系统。它功能强大，可以方便地实现各种复杂实体和模型的构建。它在诞生之初主要是基于工作站，但随着PC硬件的发展和个人用户的快速增长，...
- 2年前缒幕的博客 你做的页面在哪些流览器测试过？这些浏览器的内核分别是什么? 21 每个HTML文件里开头都有个很重要的东西，Doctype，知道这是干什么的吗？ 21 Quirks模式是什么？它和Standards模式有什么区别 21 div+css的布局较...