Commit Graph

435 Commits

Author SHA1 Message Date
nathan
f6bf52c57f Added JCTools MPMC queue, added more benchmark tests, WIP simpleQ 2015-04-09 23:08:12 +02:00
nathan
9acffac11b wip exchanger. wip simpleq 2015-03-01 12:29:35 +01:00
nathan
3c021f383c WIP disruptor. WIP simple queue 2015-03-01 02:23:41 +01:00
nathan
e257aced31 polish 2015-02-28 01:30:51 +01:00
nathan
7d410e78be Code cleanup, restored sub/unsub unit test to original version 2015-02-28 01:13:11 +01:00
nathan
45614e8bdd WIP cleanup, unit tests 2015-02-27 16:32:05 +01:00
nathan
dd31c45dc3 Moved project to dorkbox name. WIP multi-messages, and vararg/vararg-superclass 2015-02-27 00:01:38 +01:00
nathan
01f87da371 Added StrongConcurrentSetV8, WIP - var arg. Added boolean to skip checking for subtypes/varargs. Code polish 2015-02-26 16:15:48 +01:00
nathan
b8f06b7c33 Changed to single access for sub/unsub (now passes unit tests). Changed to ConcurrentHashMapV8, 174/87 ns/op 2015-02-24 14:26:32 +01:00
nathan
4eef758e89 changed striping to num_threads. 176/100 ns/op 2015-02-22 23:20:07 +01:00
nathan
b42eb86531 Small amount of code polish. 186/93 ns/op 2015-02-22 23:10:15 +01:00
nathan
0171a5558c WIP - now have superclass path enabled. @ 192 ns/op 2015-02-22 02:39:08 +01:00
nathan
3315f079d5 Tuned concurrency 2015-02-20 20:21:00 +01:00
nathan
d0584d52b0 Cuncurrent sub/pub. 169ish ns/op VS 256 ns/op 2015-02-20 19:54:53 +01:00
nathan
2be96d7ff6 Now have 300ms publication for both 2/4million handled events 2015-02-20 15:43:39 +01:00
nathan
758a1c837a Changed superClassSubs to use fast iterator 2015-02-20 12:17:07 +01:00
nathan
13cee46f6c WIP - more even dist of performance (smaller up/down spikes). Using faster collections. SUB/UNSUB is write-locked 2015-02-20 01:46:03 +01:00
nathan
86d04c899c WIP - getting better performance, using non-blocking. around 300ms for 2million, 550 for 4million 2015-02-19 18:39:05 +01:00
nathan
120054afd4 WIP - playing with concurrent maps + ability to have non-blocking for updates 2015-02-19 17:52:48 +01:00
nathan
8b69d53263 WIP, cleaning code. Getting multi-arg versions working 2015-02-17 22:43:48 +01:00
nathan
40d8bb70bd NOT MPMC, LTQ - fastest so far via using non-copy interation for subscriptions 2015-02-17 07:59:45 +01:00
nathan
67c68dbc14 WIP - best performance for low cores 2015-02-17 00:26:46 +01:00
nathan
a91b3af27f it's slower, not sure if correct direction 2015-02-16 23:37:41 +01:00
nathan
d1338ad46c Cleaned/removed disruptor 2015-02-13 17:59:13 +01:00
nathan
9b0e0c2bb6 wip, wrapping up 2015-02-13 17:19:10 +01:00
nathan
139f4c3069 using disruptor + LTQ 2015-02-13 11:02:43 +01:00
nathan
3418b08529 WIP. have LinkedTransferQueue working, so far is the best 2015-02-12 21:51:10 +01:00
nathan
220e522ff0 Changed reflection to use (much faster) ReflectASM 2015-02-08 14:51:30 +01:00
nathan
2e7cc11799 Updated readme for 'Multi' version of MBassador 2015-02-08 00:42:16 +01:00
nathan
9fca48fce5 Fixed unit tests. removing ALL subscriptions is the same as starting new. 2015-02-08 00:28:29 +01:00
nathan
4fd1a95f20 Merge branch 'master' of https://github.com/dorkbox/mbassador
Conflicts:
	src/main/java/net/engio/mbassy/listener/MessageListener.java
	src/test/java/net/engio/mbassy/MetadataReaderTest.java
2015-02-08 00:27:47 +01:00
nathan
f1d8ae0e6a Changed removed behavior back to orig. Added isEmpty() method to satisfy requirement 2015-02-07 22:31:09 +01:00
nathan
45fbc56320 Added removeLeaf from object tree. CHANGED concurrentSet.remove() to return TRUE (as atomic operation) if the set is empty when the element is removed. Fixed unsubscript(listener). 2015-02-07 22:26:01 +01:00
nathan
113ffb5e4a Added remaining arg 1/2/3 methods. Fixed VarArg array construction for calling handlers that are VarArg. WIP disruptor handling 2015-02-07 16:20:34 +01:00
nathan
c69e3c686e Updated license info 2015-02-07 01:35:38 +01:00
nathan
e1472413ce MultiArgument messaging working with VarArg handlers as optional 2015-02-06 02:59:23 +01:00
nathan
fb985b6ef1 Using the disruptor to deliver messages instead of a BlockingQueue+threads 2015-02-05 03:52:31 +01:00
nathan
c0d19fcde4 WIP var-args 2015-02-05 03:06:40 +01:00
nathan
7f48f9eeed Removed 'unit test' code from MessageListener. Cleaned up MetadataReaderTest 2015-02-05 02:17:00 +01:00
nathan
0202c937ce Wip - getting var-args for messages/subscription working 2015-02-05 02:03:09 +01:00
nathan
d46a773286 Fixed warning in WeakConcurrentSet 2015-02-04 02:36:28 +01:00
nathan
e0b9d8addb Fixed warning in AbstractConcurrentSet 2015-02-04 02:35:36 +01:00
nathan
ff4dd6271f Deleted configuration. Changed to single parameter for thread count in constructor 2015-02-04 02:33:47 +01:00
nathan
226a5f80a2 Moved error handling, code polish 2015-02-04 01:44:40 +01:00
nathan
2338c0ab18 Removed 'MessagePublication' functionality, and now directly publishes messages 2015-02-04 01:14:29 +01:00
nathan
8ed29f6b7f Further simplification of mbassador 2015-02-03 22:32:50 +01:00
nathan
d17183d592 Simplifying/pruning mbassador functionality and complexity 2015-02-03 18:49:43 +01:00
Benjamin Diedrichsen
f509bfe57f Merge pull request #91 from dorkbox/master
Extend the message publication factory to return an interface type instead of class type to allow for easier extension of message publication behaviour
2014-12-18 12:40:20 +01:00
nathan
7b3032877a Factory returns interface instead of object to allow for extending message publication 2014-11-16 14:32:43 +01:00
nathan
1bb957769f Added eclipse classes dir and libs to .gitignore 2014-11-16 01:11:35 +01:00