Test concurrency fun

test-concurrency.scala

import sbt._
import Keys._
 
object TestBuild extends Build {
  lazy val root = Project(id = "root", base = file(".")).aggregate(project1, project2).settings(defaultSettings:_*).settings(
    concurrentRestrictions in Global := Seq(
      Tags.limit(Tags.ForkedTestGroup, 1)
    )
  )
 

  val okToRun = new java.util.concurrent.atomic.AtomicBoolean(true)

  lazy val project1 = Project("project1", file("project1")).settings(defaultSettings:_*).settings(
      libraryDependencies += "org.specs2" %% "specs2" % "2.1.1" % "test"
    )
 
  lazy val project2 = Project("project2", file("project2")).settings(defaultSettings:_*).settings(
      libraryDependencies += "org.specs2" %% "specs2" % "2.1.1" % "test"
    )
 
  lazy val defaultSettings = Seq(
    parallelExecution in Test := false,
    testOptions in Test += Tests.Setup( () => startupDb(name.value) ),
    testOptions in Test += Tests.Cleanup( () => shutdownDb(name.value) )
  )
 
  def startupDb(name: String) = {
    System.err.println(s"startup ${name}, thread name = " + Thread.currentThread().getName)
    assert(okToRun.compareAndSet(true, false), "Failed to safely grab the ok to run lock!")
  }
  
  def shutdownDb(name: String) = {
    System.err.println(s"shutdown ${name}, thread name = " + Thread.currentThread().getName)
    assert(okToRun.compareAndSet(false, true), "Failed to safely release the ok to run lock!")
  }
}