Stephen Coakley
c6d350d802
Update example to demonstrate concurrency
2015-12-11 22:44:51 -06:00
Stephen Coakley
c7d2357c81
Fix shutdown errors while a task is running
2015-12-11 22:44:25 -06:00
Stephen Coakley
2d001c5bfe
Handle rapidly enqueued tasks on workers
2015-12-11 18:15:15 -06:00
Stephen Coakley
d8b21c3283
Remove unused constant
2015-12-11 17:13:02 -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
fe9a213431
Add null bytes as validity check
2015-12-05 00:54:15 -06:00
Aaron Piotrowski
dae18271e8
Update travis build
2015-12-04 23:54:55 -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
Aaron Piotrowski
dd9479d8bb
Update branch name
2015-12-04 21:46:17 -06:00
Stephen Coakley
bec2a19e20
Update change log for v0.1.1
2015-11-13 21:22:12 -06:00
Stephen Coakley
a392132299
Add tests and fix process killing not detaching
2015-11-11 02:59:22 -06:00
Stephen Coakley
8f22150160
Add methods for checking fork/thread availability and unsupported checks
2015-11-11 01:07:59 -06:00
Stephen Coakley
48ea5a2b42
Merge pull request #9 from yched/pool_maxsize
...
Fix $maxSize being ignored in Pool constructor
2015-11-08 14:02:26 -06:00
Yves Chedemois
486a3e4c7a
Pool $maxSize was ignored
2015-11-08 15:49:35 +01:00
Aaron Piotrowski
a71abaf61d
Fix issue with error handler
...
Using yield within the try block caused the error handler to persist through the next loop iteration, catching any error.
2015-10-28 18:50:01 -05:00
Aaron Piotrowski
c25608c893
Refactor ContextInterface and add ProcessInterface
2015-10-20 00:06:43 -05:00
Aaron Piotrowski
80d5c4cd08
Refactor reading from code stream
2015-10-19 21:44:42 -05:00
Aaron Piotrowski
70718e6833
Rename process.php to worker.php
2015-10-19 18:07:20 -05:00
Aaron Piotrowski
15904cdd87
Update dependencies
2015-10-19 18:06:49 -05: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
Stephen Coakley
8d9e6200a7
Documentation fixes
2015-10-16 23:32:01 -05:00
Aaron Piotrowski
ef5ab2f575
Update to icicleio/stream v0.4.0
2015-10-16 18:20:20 -05:00
Aaron Piotrowski
1cf7dd62b9
Better Windows support
2015-09-28 21:03:55 -05:00
Aaron Piotrowski
cf1455b239
Update documentation
2015-09-27 23:45:56 -05:00
Aaron Piotrowski
8695d600fc
Update examples with BlockingTask
2015-09-27 22:46:57 -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
02b41543d0
Mark worker as shutdown immediately
2015-09-25 18:01:35 -05:00
Aaron Piotrowski
a236585aae
Add missed owner property; other minor fixes
2015-09-19 21:34:41 -05:00
Aaron Piotrowski
4eb815ea45
Automatically kill on destruct again
2015-09-18 22:20:35 -05:00
Aaron Piotrowski
c021add891
Merge branch 'master'
2015-09-18 22:19:27 -05:00
Aaron Piotrowski
4a804536f2
Refactor process to unreference exit code stream
2015-09-18 15:07:59 -05:00
Aaron Piotrowski
dbda7e6506
Update dependencies
2015-09-18 15:07:30 -05:00
Stephen Coakley
a00e83b323
Add Slack <- Travis integration for fun
2015-09-14 23:14:21 -05:00
Aaron Piotrowski
b14fc0a4bb
Update license
2015-09-14 21:28:25 -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
41ec732092
Fix hang when killing a process
2015-09-11 14:47:54 -05:00
Aaron Piotrowski
9f551abbd1
Rename TaskError to TaskException
2015-09-11 12:39:51 -05:00
Aaron Piotrowski
fae5bdef5b
Combine unsets
2015-09-11 10:38:13 -05:00
Aaron Piotrowski
6c71eb515f
Fix TTL update in get() and set()
2015-09-11 00:18:37 -05:00
Aaron Piotrowski
fbd77068c9
Improve Environment
2015-09-10 18:37:34 -05:00
Aaron Piotrowski
ae267e64ac
Add worker environment
2015-09-09 23:29:41 -05:00