🖉 #1011783 | BotCompany.de Repo

Warning: session_start(): open(/var/lib/php/sessions/sess_67h2odj4epcnmb9aobumfoa2d2, O_RDWR) failed: No space left on device (28) in /var/www/tb-usercake/models/config.php on line 51

Warning: session_start(): Failed to read session data: files (path: /var/lib/php/sessions) in /var/www/tb-usercake/models/config.php on line 51
🖉 #1011783 | BotCompany.de Repo

Editing Snippet ID:	#1011783
Snippet name:
Category, Type:
Content:	static L<Web> webs_readTripleFile_parallel(File f) ctex { if (!f.exists()) ret ll(); print("Reading " + f2s(f) + " in " + nCore(numberOfCores())); time "webs_readTripleFile_parallel" { time "Reading names" { Iterator<S> it = linesFromFile(f); final new L<S> names; while (it.hasNext()) { S s = trim(it.next()); if (empty(s)) break; names.add(unquote(s)); } } final new L<Pair<Web, Int>> webs; int poolSize = numberOfCores(), queueSize = 1000; NotifyingBlockingThreadPoolExecutor e = new(poolSize, queueSize, 15, TimeUnit.SECONDS); try { int i = 0; for (fS s : iterable(it)) { ++i; final int _i = i; e.execute(r { pcall { Web web = webs_readTripleFile_line(s, names); if (web != null) synchronized(webs) { webs.add(pair(web, _i)); } }}); } e.shutdown(); e.awaitTermination(1, TimeUnit.DAYS); } finally { e.shutdown(); } L<Web> result = firstOfPairs(sortBySecondOfPairs_inPlace(webs)); } ret result; }
Comment:	Began life as a copy of #1011762
Public (visible to everyone):
Created:	2017-11-05 04:26:33

This page with fancy editor.