File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
core/src/main/scala/com/phaller/rasync/pool Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -106,7 +106,7 @@ class HandlerPool[V, E >: Null](
106106 @ tailrec
107107 final def onQuiescent (handler : () => Unit ): Unit = {
108108 val state = poolState.get()
109- if (state.isQuiescent) {
109+ if (state.isQuiescent() ) {
110110 execute(new Runnable { def run (): Unit = handler() }, 0 )
111111 } else {
112112 val newState = new PoolState (handler :: state.handlers, state.submittedTasks)
@@ -141,7 +141,7 @@ class HandlerPool[V, E >: Null](
141141
142142 /** Returns all non-completed cells, when quiescence is reached. */
143143 def quiescentIncompleteCells : Future [Iterable [Cell [_, _]]] = {
144- val p = Promise [Iterable [Cell [_, _]]]
144+ val p = Promise [Iterable [Cell [_, _]]]()
145145 this .onQuiescent { () =>
146146 deregisterCompletedCells()
147147 p.success(cellsNotDone.asScala)
@@ -160,7 +160,7 @@ class HandlerPool[V, E >: Null](
160160 * boolean parameter indicates if cycles have been resolved or not.
161161 */
162162 def quiescentResolveCell : Future [Unit ] = {
163- val p = Promise [Unit ]
163+ val p = Promise [Unit ]()
164164 this .onQuiescent { () =>
165165 deregisterCompletedCells()
166166
You can’t perform that action at this time.
0 commit comments