1
0
mirror of https://github.com/danog/parallel.git synced 2024-12-14 10:08:24 +01:00
Commit Graph

604 Commits

Author SHA1 Message Date
coderstephen
b0ebadedf6 New shared memory object that stores a single value 2015-08-09 22:16:34 -05:00
coderstephen
df5db8ac4e Make destroying ThreadedMutex explicit 2015-08-07 23:30:48 -05:00
coderstephen
ed34e1e5d9 Remove unneeded mutex and semaphore implementations 2015-08-07 23:13:33 -05:00
coderstephen
f109bd926f Update FileMutex to be async 2015-08-07 23:12:21 -05:00
coderstephen
71f25e9def Add tiny unit test for ThreadedMutex 2015-08-07 22:50:20 -05:00
coderstephen
35bdedf390 Add a thread-safe mutex and update MutexInterface to be non-blocking 2015-08-07 22:45:41 -05:00
Aaron Piotrowski
ed08c738d5 Use array instead of SplQueue 2015-08-07 20:19:34 -05:00
coderstephen
eb91972489 Merge branch 'master' of github.com:icicleio/concurrent 2015-08-07 15:32:39 -05:00
coderstephen
000de5ba12 New threaded async semaphore, with a better semaphore API 2015-08-07 15:32:18 -05:00
Aaron Piotrowski
1b77f37693 Add executor contexts, bind to executors instead of channel 2015-08-07 15:30:14 -05:00
coderstephen
50444e41e3 Move all semaphores to Sync namespace 2015-08-07 13:23:33 -05:00
coderstephen
18c23ef88d Update channel test to use createSocketPair 2015-08-07 01:38:53 -05:00
Aaron Piotrowski
078f915081 Rebind $this to channel 2015-08-07 00:07:53 -05:00
Aaron Piotrowski
dc3cd5155e Add ability to pass arguments to context function 2015-08-06 23:25:04 -05:00
coderstephen
4d90dc5ca7 Merge channel changes 2015-08-06 22:24:45 -05:00
Aaron Piotrowski
399764f7b9 Remove file_exists() check 2015-08-06 21:51:45 -05:00
Aaron Piotrowski
c34d1331af Fix exit error messages 2015-08-06 20:56:30 -05:00
Aaron Piotrowski
4ca84144b0 Update and fix forking code 2015-08-06 20:54:57 -05:00
Aaron Piotrowski
c52ec19a38 Refactor contexts and exiting 2015-08-06 18:59:25 -05:00
Aaron Piotrowski
d0ec5d677e Updated dependencies 2015-08-06 18:17:32 -05:00
Aaron Piotrowski
b5d97eb9d5 Fix reading from channel 2015-08-05 21:13:29 -05:00
Aaron Piotrowski
43d4b53ac2 Fix reading from channel 2015-08-05 18:48:20 -05:00
coderstephen
09edc25348 Add more to docs 2015-08-05 16:00:29 -05:00
coderstephen
d95ee80cb8 Faster object ID selection 2015-08-05 15:44:53 -05:00
coderstephen
1ece940057 Fix channel coroutines to yield correct values 2015-08-05 13:30:05 -05:00
coderstephen
641946e3a8 Update context interface with create method and clean up ThreadContext 2015-08-05 13:29:11 -05:00
coderstephen
865979188c Copy global parameters and environment values to threads 2015-08-05 12:41:37 -05:00
coderstephen
63ad35cec1 Remove unused exception type 2015-08-05 11:36:37 -05:00
coderstephen
ab32b4b88e More docs 2015-08-05 11:35:42 -05:00
coderstephen
bc5501a39e Merge back into one test suite 2015-08-05 11:29:22 -05:00
coderstephen
3855d8b5e9 Add handling for cloning local objects 2015-08-05 11:19:48 -05:00
coderstephen
712a4b69d2 More tests for LocalObject 2015-08-05 03:53:43 -05:00
coderstephen
cac4bdf71e Use LocalObject to store local storage array 2015-08-05 03:45:35 -05:00
coderstephen
f648c5febb Make sure object ID is unique 2015-08-05 02:52:45 -05:00
coderstephen
5fb2b0ee64 Update provisioning to provide xdebug for code coverage & auto-load extensions 2015-08-05 02:51:04 -05:00
coderstephen
ff413c904c First working, async threads using channels for messages
Channel was changed to return resources on creation.

Also, much better setting up synchronization at the beginning of a new
thread.
2015-08-05 02:48:43 -05:00
coderstephen
ced3ddc8ff New class for storing non-thread-safe objects in thread-local memory 2015-08-05 02:21:49 -05:00
coderstephen
a372328534 LocalStorage class for storing unsafe data inside a thread 2015-08-03 16:07:58 -05:00
coderstephen
e2577a6ab1 Update docs 2015-08-03 15:11:58 -05:00
coderstephen
5cd8353fcc Store panic info inside an error 2015-08-03 15:11:27 -05:00
coderstephen
b9cef10633 Add panic method for panicking a context from either side 2015-08-03 15:10:59 -05:00
coderstephen
8ac9301105 Update fork example 2015-08-03 15:10:20 -05:00
coderstephen
e388e08f4f Update thread example to use coroutines 2015-08-03 15:09:26 -05:00
coderstephen
c110d4baa6 Use Channel for fork messages 2015-08-03 15:08:27 -05:00
coderstephen
7919a0df38 Add better socket checking and error handling
Also update send() to return a generator.
2015-08-03 01:22:17 -05:00
coderstephen
f121adb577 Get rid of coroutine wrapper 2015-08-03 00:58:08 -05:00
coderstephen
bf6c46b2d0 Add test suite for just threading tests 2015-08-03 00:31:01 -05:00
coderstephen
db5469a9cf Exception for channels 2015-08-03 00:29:41 -05:00
coderstephen
25804d70c3 Add benchmark for socket pairs 2015-08-03 00:28:38 -05:00
coderstephen
fe54634462 Basic channel test 2015-08-03 00:20:06 -05:00