MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-10 13:17:09 +07:00
Code Issues Packages Projects Releases Wiki Activity

ConcurrentIndexTest: don't hang on computers with odd core count, fix more tests

Browse Source
This commit is contained in:
peter
2017-03-30 08:47:30 +02:00
parent 1c1af4e34c
commit 3167a61dcb
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/java-tests/testSrc/com/intellij/index/ConcurrentIndexTest.groovy
+7 -5
View File
@@ -48,6 +48,7 @@ class ConcurrentIndexTest extends JavaCodeInsightFixtureTestCase {
void "test concurrent switching with checkCanceled"() {
def N = Math.max(2, (int)(Runtime.runtime.availableProcessors()))
def halfN = N / 2
for (iteration in 1..200) {
def name = "Foo" + iteration
// if (iteration % 10 == 0) println "Finding $name"
@@ -57,7 +58,7 @@ class ConcurrentIndexTest extends JavaCodeInsightFixtureTestCase {
def futuresToWait = []
def sameStartCondition = new CountDownLatch(N)
for(i in 1.. N/2) {
for(i in 1.. halfN) {
futuresToWait.add(ApplicationManager.application.executeOnPooledThread {
sameStartCondition.countDown()
sameStartCondition.await()
@@ -71,7 +72,7 @@ class ConcurrentIndexTest extends JavaCodeInsightFixtureTestCase {
})
}
for(i in 1..N/2) {
for(i in 1..(N - halfN)) {
futuresToWait.add(ApplicationManager.application.executeOnPooledThread {
sameStartCondition.countDown()
sameStartCondition.await()
@@ -95,6 +96,7 @@ class ConcurrentIndexTest extends JavaCodeInsightFixtureTestCase {
void "test cancellable and non-cancellable progress"() {
def N = Math.max(2, (int)(Runtime.runtime.availableProcessors()))
def halfN = N / 2
PsiFileImpl file = (PsiFileImpl) myFixture.addFileToProject("Foo.java", "class Foo {" + ("public void foo() {}\n") * 1000 + "}")
assert myFixture.findClass("Foo").node
@@ -109,7 +111,7 @@ class ConcurrentIndexTest extends JavaCodeInsightFixtureTestCase {
def futuresToWait = []
def sameStartCondition = new CountDownLatch(N)
for(j in 1..N/2) {
for(j in 1..halfN) {
futuresToWait.add(ApplicationManager.application.executeOnPooledThread {
new BombedProgressIndicator(10).runBombed {
ApplicationManager.application.runReadAction {
@@ -121,7 +123,7 @@ class ConcurrentIndexTest extends JavaCodeInsightFixtureTestCase {
})
}
for(j in 1..N/2) {
for(j in 1..(N - halfN)) {
futuresToWait.add(ApplicationManager.application.executeOnPooledThread {
ApplicationManager.application.runReadAction {
sameStartCondition.countDown()
@@ -137,6 +139,7 @@ class ConcurrentIndexTest extends JavaCodeInsightFixtureTestCase {
void "test forceUpdateAffectsReadOfDataForUnsavedDocuments"() {
def N = Math.max(2, (int)(Runtime.runtime.availableProcessors()))
def halfN = N / 2
PsiFileImpl file = (PsiFileImpl) myFixture.addFileToProject("Foo.java", "class Foo {" + ("public void foo() {}\n") * 1000 + "}")
assert myFixture.findClass("Foo").node
@@ -153,7 +156,6 @@ class ConcurrentIndexTest extends JavaCodeInsightFixtureTestCase {
def futuresToWait = []
def sameStartCondition = new CountDownLatch(N)
def halfN = N / 2
for(j in 1..halfN) {
futuresToWait.add(ApplicationManager.application.executeOnPooledThread {
ApplicationManager.application.runReadAction {