Fibers, Channels and Actors for the JVM
quasar-galaxy module has been removedco.paralleluniverse.data.record has been removed from the quasar-actors module.verifyInstrumentation (#280, #279)verifyInstrumentation (#238, #255)FiberAsync.runBlocking interrupts the thread executing the operation (#245)ExitMessages received from actors after they've been unlinked/unwatched will be ignored (#163)Various small fixes.
Improvements to verifyInstrumentation reporting and some bug fixes.
This release contains a fix to a major bug
#204
a fix to a medium-severity bug
#212
an improvement to handling multiple class loaders
#196
as well as minor bug fixes.
ThreadLocals serialization in fibers is now optionalThreadLocals serialization in fibers1.0.1-2
TransferChannel raceModuleDescriptorImpl
select, thanks and related to https://groups.google.com/forum/#!topic/quasar-pulsar-user/U2ztEdoPFqw with Chris PennelloMessageSelector.select() results requires cast to MessageSelector<Object,Object> in order to be usedCountDownLatch and CyclicBarrier
build-1.0.0-beta-4584 supportselect type constraintsquasar-disruptor subproject (still experimental)fiber function has been moved to the co.paralleluniverse.kotlin package, has several convenient overloads and by default will also start the fiber.co.paralleluniverse.kotlin also includes a convenient select syntax to perform channel selection:val ch1 = Channels.newChannel<Int>(1)
val ch2 = Channels.newChannel<Int>(1)
assertTrue (
fiber {
select(Receive(ch1), Send(ch2, 2)) {
it
}
}.get() is Send
)
ch1.send(1)
assertTrue (
fiber {
select(Receive(ch1), Send(ch2, 2)) {
when (it) {
is Receive -> it.msg
is Send -> 0
else -> -1
}
}
}.get() == 1
)
FiberForkJoinScheduler.onIdle() hook notifies when the fiber scheduler becomes idle.quasar-reactive-streams module0.12.613(post-M12) and several other dependencies upgrade@Suspendable annotation is now supported on individual interface methods rather than just on the whole interfacescanSuspendables has been addressed, it sometimes included unnecessary (but harmless) lines in suspendable-supers
gradle