1
0
mirror of https://github.com/danog/parallel.git synced 2024-12-13 09:37:26 +01:00
Commit Graph

73 Commits

Author SHA1 Message Date
Aaron Piotrowski
14f2d6d707 Update with PHP 7 features 2016-01-23 00:00:56 -06:00
Aaron Piotrowski
b54ef2e01b Update function tests
Mocks were causing some tests to hang... will look at fixing later.
2016-01-15 09:06:57 -06:00
Aaron Piotrowski
5d5119d600 Combine pool and queue; rename pull() to get() 2016-01-14 18:54:53 -06:00
Aaron Piotrowski
e259e956ca Rename test and add function tests 2016-01-14 18:08:06 -06:00
Aaron Piotrowski
55f3e1aace Automatically push workers back into the queue 2016-01-14 17:05:31 -06:00
Aaron Piotrowski
c08f6c9058 Keep track of times pulled in DefaultQueue; add more tests 2015-12-16 17:43:14 -06:00
Aaron Piotrowski
78b8741537 Fix hanging queue test 2015-12-16 17:19:31 -06:00
Aaron Piotrowski
cbc5e4e75e Use null as defaults 2015-12-16 16:39:25 -06:00
Aaron Piotrowski
d73de0dd5d Update Pool and DefaultPool 2015-12-16 15:53:53 -06:00
Aaron Piotrowski
b286c96eb1 Add Queue and DefaultQueue 2015-12-16 15:53:39 -06:00
Aaron Piotrowski
f7fb6d6ecc Fix process workers; add process pool test 2015-12-16 11:16:21 -06:00
Stephen Coakley
9a5c03e904 Fix #11 2015-12-12 00:34:41 -06:00
Stephen Coakley
3c2979c18f Fix tests 2015-12-11 23:31:50 -06:00
Stephen Coakley
347132825e Gut lame factories 2015-12-11 23:28:44 -06:00
Stephen Coakley
957f4d7f4d Eliminate race conditions and update tests 2015-12-11 22:47:46 -06:00
Stephen Coakley
2d001c5bfe Handle rapidly enqueued tasks on workers 2015-12-11 18:15:15 -06:00
Aaron Piotrowski
77f45f3d6b Update exception classes 2015-12-06 00:40:48 -06:00
Aaron Piotrowski
fdcc182955 Rename to ChannelledStream
Use only one byte for verificaiton
2015-12-06 00:32:06 -06:00
Aaron Piotrowski
b994cab086 Minor updates and tweaks 2015-12-05 01:09:42 -06:00
Aaron Piotrowski
5bca326354 Remove Interface suffixes 2015-12-04 23:50:32 -06:00
Aaron Piotrowski
92a26930ee Update for Icicle v0.9 2015-12-04 21:54:55 -06:00
Stephen Coakley
a392132299 Add tests and fix process killing not detaching 2015-11-11 02:59:22 -06:00
Aaron Piotrowski
7080310afa Pass parcel value to synchronized()
Remove wrap() method from interface. Wrapped value should be returned from the synchronized() callback function or can be passed by-reference to the callback function.
2015-10-18 02:12:46 -05:00
Aaron Piotrowski
c7de1ae603 Combine channel interfaces; remove executor classes 2015-10-18 01:54:09 -05:00
Aaron Piotrowski
8625e5968e Fix bug reading long data from channel 2015-09-27 22:34:50 -05:00
Aaron Piotrowski
69d85ea8e2 Use pcntl_waitpid() instead of sleeping 2015-09-27 00:20:06 -05:00
Stephen Coakley
283a35ee6d Increase delay 2015-09-26 01:33:40 -05:00
Stephen Coakley
82c977bb9a Fix test conflicts with forks not ready yet 2015-09-26 01:30:44 -05:00
Stephen Coakley
d3038f9597 Fix FileMutex when acquiring multiple times
Also fix ParcelTest.
2015-09-26 00:50:25 -05:00
Stephen Coakley
dd35995792 Add fork and lock tests and some cleanup 2015-09-25 23:41:15 -05:00
Aaron Piotrowski
7def2ae5a3 No longer call kill() in destructors
This means forks/processes/threads must be properly shutdown or killed before a reference is lost or the thread will continue to run indefinitely. This was necessary because forks were automatically killing other processes or threads due to calling kill() in the destructor.
2015-09-14 18:59:33 -05:00
Aaron Piotrowski
ae267e64ac Add worker environment 2015-09-09 23:29:41 -05:00
Aaron Piotrowski
ff44afde6d Remove Channel::createSocketPair(); refactor Thread 2015-09-04 16:22:41 -05:00
Aaron Piotrowski
3071dee6c8 Improve semaphore tests 2015-09-03 23:23:12 -05:00
Aaron Piotrowski
3c93d2c383 Update tests and coverage annotations; fix some docs 2015-09-03 18:10:19 -05:00
Aaron Piotrowski
a281e34077 Update Channel and add more tests 2015-09-02 18:29:48 -05:00
Aaron Piotrowski
45a54f3f78 Update Thread; add more tests 2015-09-02 16:34:42 -05:00
Aaron Piotrowski
9f86336edd Merge branch 'master' of https://github.com/icicleio/concurrent
Conflicts:
	tests/Threading/ThreadTest.php
2015-08-31 14:13:54 -05:00
Aaron Piotrowski
0e7944afea Check if thread is running before killing 2015-08-31 14:12:38 -05:00
coderstephen
a0a5dafdb6 Try to fix testKill occasionally hanging 2015-08-31 14:04:42 -05:00
coderstephen
b212d00735 Fix timing in sync tests 2015-08-31 14:00:07 -05:00
Aaron Piotrowski
1ba162da36 Fix fork killing; fix timing in tests 2015-08-31 13:30:07 -05:00
coderstephen
3ee7e7ab0d Fix worker tests to not use kill() so much 2015-08-31 12:57:40 -05:00
coderstephen
d37052615e Doc fixes 2015-08-31 12:26:11 -05:00
coderstephen
ec3f5621b7 Implement fast algorithm for POSIX semaphores 2015-08-31 04:22:42 -05:00
coderstephen
1fe1374c8a Fix & improve tests; add thread start error check 2015-08-30 18:25:44 -05:00
Aaron Piotrowski
b0ddd761a6 Remove LocalObject and LocalStorage 2015-08-29 01:03:46 -05:00
coderstephen
ef90b760e4 Add some tests for workers 2015-08-28 20:55:30 -05:00
coderstephen
725d94f379 More tests 2015-08-28 16:58:15 -05:00
coderstephen
9559d32241 Fix broken tests & add skips when extension needed 2015-08-28 15:09:07 -05:00